i^ddlZddlmZddlmZmZddlmZddlm Z ddl m Z m Z Gdd e Z Gd d e ZGd de ZGdde ZGdde ZGdde ZdS)N) connection)AnyUnion)errors) BaseMetaClass)DbObject DbObjectTypeceZdZedZddZeddZedd Zedd Z edd Z eddZ ede fdZ edeedffdZedeedffdZdS) BaseQueuec||}||_t|j|_t |j|_d|_ ||_ |SN) __new__ _connection DeqOptions _from_impldeq_options_impl _deq_options EnqOptionsenq_options_impl _enq_options _payload_type_impl)clsrimplqueues [/var/www/html/Pagina-Ingenieria-Requisitos/venv/lib/python3.11/site-packages/oracledb/aq.pyrzBaseQueue._from_impl*sa C  &'2243HII'2243HII"  messageMessagePropertiesreturnNct|tstd|jt jtjt|jtrQt|jtr|jj |jkr t jtj dSdS|jdkrCt|jttfs t jtj dSdSt|jttfs t jtj dSdS)z? Internal method used for verifying a message. z"expecting MessageProperties objectNJSON) isinstancer TypeErrorpayloadr _raise_errERR_MESSAGE_HAS_NO_PAYLOAD payload_typer r typeERR_PAYLOAD_CANNOT_BE_ENQUEUEDdictliststrbytesselfrs r_verify_messagezBaseQueue._verify_message4s3'#455 B@AA A ? "  f? @ @ @ d' 6 6 Iw99 I?'4+<<<!&"GHHHHH=< & ( (god|<< I!&"GHHHHH I IgoU|<< I!&"GHHHHH I Irconnection_module.Connectionc|jS)z This read-only attribute returns a reference to the connection object on which the queue was created. )rr1s rrzBaseQueue.connectionIs rrc|jS)z This read-only attribute returns a reference to the options that will be used when dequeuing messages from the queue. )rr5s r deqoptionszBaseQueue.deqoptionsQ   rc|jS)z5 Deprecated: use deqoptions instead. )r7r5s r deqOptionszBaseQueue.deqOptionsY rrc|jS)z This read-only attribute returns a reference to the options that will be used when enqueuing messages into the queue. )rr5s r enqoptionszBaseQueue.enqoptions`r8rc|jS)z7 Deprecated: use enqoptions() instead. )r=r5s r enqOptionszBaseQueue.enqOptionshr;rc|jjS)zI This read-only attribute returns the name of the queue. )rnamer5s rrAzBaseQueue.nameos zrc|jC|jjrd|_n/|jj#t j|jj|_|jS)z This read-only attribute returns the object type for payloads that can be enqueued and dequeued. If using a JSON queue, this returns the value "JSON". If using a raw queue, this returns the value *None*. Nr#)rris_jsonr)r rr5s rr)zBaseQueue.payload_typevsX   %z! %+""(4%1%<J+&&"!!rc|jS)z7 Deprecated: use payload_type instead. )r)r5s r payloadTypezBaseQueue.payloadTypes   rrr r!N)r!r3)r!r)r!r)__name__ __module__ __qualname__ classmethodrr2propertyrr7r:r=r?r.rArr r)rErrr r )sn[IIII*   X !!!X!X !!!X!X cX  "eL$$67 " " "X "!U<#56!!!X!!!rr ) metaclassceZdZdededfdZdededfdZdedfdZdedfdZ d eddd fd Z d eddd fd Z ddZ ddZ d S)Queuemax_num_messagesr!r cJ|j|jjr|j|}nYg}t ||krD|j}|n(||t ||kDd|DS)~ Dequeues up to the specified number of messages from the queue and returns a list of these messages. NcBg|]}t|SrLr r.0rs r z!Queue.deqmany..'MMMt!,,T22MMMr)r_supports_deq_manyrdeq_manylendeq_oneappend)r1rP message_impls message_impls rdeqmanyz Queue.deqmanys : ( ()9)? @ @ 3 J//0@AAMMMm$$'777#z1133 '$$\222 m$$'777 NM}MMMMrc,||S)z4 Deprecated: use deqmany() instead. )r`)r1rPs rdeqManyz Queue.deqManys||,---rr Ncp|j}|t|SdSz Dequeues at most one message from the queue and returns it. If no message is dequeued, None is returned. Nrr\r rr1r_s rdeqonez Queue.deqones9 z))++  #$// == = $ #rc*|S)z3 Deprecated: use deqone() instead. )rhr5s rdeqOnez Queue.deqOnes{{}}rmessagesNc|D]}||d|D}|j|dS)a3 Enqueues multiple messages into the queue. The messages parameter must be a sequence containing message property objects which have all had their payload attribute set to a value that the queue supports. Warning: In python-oracledb Thick mode using Oracle Client libraries prior to 21c, calling :meth:`Queue.enqmany()` in parallel on different connections acquired from the same connection pool may fail due to Oracle bug 29928074. To avoid this, do one of: upgrade the client libraries, ensure that :meth:`Queue.enqmany()` is not run in parallel, use standalone connections or connections from different pools, or make multiple calls to :meth:`Queue.enqone()`. The function :meth:`Queue.deqmany()` call is not affected. cg|] }|j SrLrrVms rrWz!Queue.enqmany..333Q333rNr2renq_manyr1rkrr^s renqmanyz Queue.enqmanysY  * *G   ) ) ) )33(333  M*****rc,||S)z4 Deprecated: use enqmany() instead. )ru)r1rks renqManyz Queue.enqManys||H%%%rrcn|||j|jdSz Enqueues a single message into the queue. The message must be a message property object which has had its payload attribute set to a value that the queue supports. Nr2renq_oner0s renqonez Queue.enqones6 W%%% 7=)))))rc,||S)z3 Deprecated: use enqone() instead. )r|r0s renqOnez Queue.enqOnes{{7###rrF)rGrHrIintr-r`rbrrhrjrurwr|r~rLrrrOrOs$NN5H0INNNN ..5H0I.... >78>>>>78 +%8 9+d++++(&%8 9&d&&&& ****$$$$$$rrOcfeZdZdededfdZdedfdZdedddfd Zd d Z dS) AsyncQueuerPr!r c^K|j|d{V}d|DS)rRNcBg|]}t|SrLrTrUs rrWz&AsyncQueue.deqmany..rXr)rrZ)r1rPr^s rr`zAsyncQueue.deqmanysD#j112BCCCCCCCC MM}MMMMrrccK|jd{V}|t|SdSrerfrgs rrhzAsyncQueue.deqonesO "Z//11111111  #$// == = $ #rrkNcK|D]}||d|D}|j|d{VdS)al Enqueues multiple messages into the queue. The messages parameter must be a sequence containing message property objects which have all had their payload attribute set to a value that the queue supports. Warning: calling this function in parallel on different connections acquired from the same pool may fail due to Oracle bug 29928074. Ensure that this function is not run in parallel, use standalone connections or connections from different pools, or make multiple calls to enqone() instead. The function Queue.deqmany() call is not affected. cg|] }|j SrLrnros rrWz&AsyncQueue.enqmany..rqrNrrrts rruzAsyncQueue.enqmanyso  * *G   ) ) ) )33(333 j!!-00000000000rrc~K|||j|jd{VdSryrzr0s rr|zAsyncQueue.enqonesL W%%%j  ///////////rrF) rGrHrIrr-r`rrhrur|rLrrrrsN #N ! "NNNN>e$=>>>>>1d+>&?1D1111"000000rrceZdZedZedefdZejdeddfdZedefdZ e jdeddfdZ edefd Z e jdeddfd Z ede fd Z e jde ddfd Z ede fd Z e jde ddfdZ edefdZejdeddfdZede fdZejde ddfdZedefdZejdeddfdZede fdZejde ddfdZede fdZejde ddfdZdS)rc>||}||_|Srrrrroptionss rrzDeqOptions._from_impl++c"" rr!c4|jS)a5 This read-write attribute specifies a boolean expression similar to the where clause of a SQL query. The boolean expression can include conditions on message properties, user data properties, and PL/SQL or SQL functions. The default is to have no condition specified. )r get_conditionr5s r conditionzDeqOptions.conditionsz'')))rvalueNc:|j|dSr)r set_conditionr1rs rrzDeqOptions.condition s   '''''rc4|jS)a) This read-write attribute specifies the name of the consumer. Only messages matching the consumer name will be accessed. If the queue is not set up for multiple consumers this attribute should not be set. The default is to have no consumer name specified. )rget_consumer_namer5s r consumernamezDeqOptions.consumername$z++---rc:|j|dSr)rset_consumer_namers rrzDeqOptions.consumername. $$U+++++rc4|jS)az This read-write attribute specifies the correlation identifier of the message to be dequeued. Special pattern-matching characters, such as the percent sign (%) and the underscore (_), can be used. If multiple messages satisfy the pattern, the order of dequeuing is indeterminate. The default is to have no correlation specified. rget_correlationr5s r correlationzDeqOptions.correlation2sz))+++rc:|j|dSrrset_correlationrs rrzDeqOptions.correlation= ""5)))))rc td)az This write-only attribute specifies what types of messages should be dequeued. It should be one of the values :data:`~oracledb.MSG_PERSISTENT` (default), :data:`~oracledb.MSG_BUFFERED`, or :data:`~oracledb.MSG_PERSISTENT_OR_BUFFERED`. Note that :data:`~oracledb.MSG_BUFFERED` is not supported for JSON payloads. deliverymode can only be writtenAttributeErrorr5s r deliverymodezDeqOptions.deliverymodeAs?@@@rc:|j|dSrrset_delivery_moders rrzDeqOptions.deliverymodeOrrc4|jS)a= This read-write attribute specifies the locking behaviour associated with the dequeue operation. It should be one of the values :data:`~oracledb.DEQ_BROWSE`, :data:`~oracledb.DEQ_LOCKED`, :data:`~oracledb.DEQ_REMOVE` (default), or :data:`~oracledb.DEQ_REMOVE_NODATA`. )rget_moder5s rmodezDeqOptions.modeSz""$$$rc:|j|dSr)rset_moders rrzDeqOptions.mode^ E"""""rc4|jS)z This read-write attribute specifies the identifier of the message to be dequeued. The default is to have no message identifier specified. rget_message_idr5s rmsgidzDeqOptions.msgidbs z((***rc:|j|dSr)rset_message_idrs rrzDeqOptions.msgidj !!%(((((rc4|jS)a This read-write attribute specifies the position of the message that is retrieved. It should be one of the values :data:`~oracledb.DEQ_FIRST_MSG`, :data:`~oracledb.DEQ_NEXT_MSG` (default), or :data:`~oracledb.DEQ_NEXT_TRANSACTION`. )rget_navigationr5s r navigationzDeqOptions.navigationnsz((***rc:|j|dSr)rset_navigationrs rrzDeqOptions.navigationxrrc4|jS)a\ This read-write attribute specifies the name of the transformation that must be applied after the message is dequeued from the database but before it is returned to the calling application. The transformation must be created using dbms_transform. The default is to have no transformation specified. rget_transformationr5s rtransformationzDeqOptions.transformation|sz,,...rc:|j|dSrrset_transformationrs rrzDeqOptions.transformation %%e,,,,,rc4|jS)a This read-write attribute specifies the transactional behavior of the dequeue request. It should be one of the values :data:`~oracledb.DEQ_ON_COMMIT` (default) or :data:`~oracledb.DEQ_IMMEDIATE`. This attribute is ignored when using the :data:`~oracledb.DEQ_BROWSE` mode. Note the value of :attr:`~Connection.autocommit` is always ignored. rget_visibilityr5s r visibilityzDeqOptions.visibilityz((***rc:|j|dSrrset_visibilityrs rrzDeqOptions.visibilityrrc4|jS)a\ This read-write attribute specifies the time to wait, in seconds, for a message matching the search criteria to become available for dequeuing. One of the values :data:`~oracledb.DEQ_NO_WAIT` or :data:`~oracledb.DEQ_WAIT_FOREVER` can also be used. The default is :data:`~oracledb.DEQ_WAIT_FOREVER`. )rget_waitr5s rwaitzDeqOptions.waitrrc:|j|dSr)rset_waitrs rrzDeqOptions.waitrr)rGrHrIrJrrKr.rsetterrrrrrr/rrrrrrLrrrrs[ *3***X*(s(t((((.c...X.,#,$,,,,,S,,,X,****** Ac A A AX A,#,$,,,,%c%%%X% [###$###[#+u+++X+ \)5)T)))\)+C+++X+))))))////X/-C-D---- +C + + +X +))))))%c%%%X% [###$###[###rrceZdZedZedefdZejdeddfdZede fdZ e jde ddfdZ edefd Z e jdeddfd Z dS) rc>||}||_|Srrrs rrzEnqOptions._from_implrrr!c td)aB This write-only attribute specifies what type of messages should be enqueued. It should be one of the values :data:`~oracledb.MSG_PERSISTENT` (default) or :data:`~oracledb.MSG_BUFFERED`. Note that :data:`~oracledb.MSG_BUFFERED` is not supported for JSON payloads. rrr5s rrzEnqOptions.deliverymodes?@@@rrNc:|j|dSrrrs rrzEnqOptions.deliverymoderrc4|jS)a  This read-write attribute specifies the name of the transformation that must be applied before the message is enqueued into the database. The transformation must be created using dbms_transform. The default is to have no transformation specified. rr5s rrzEnqOptions.transformationsz,,...rc:|j|dSrrrs rrzEnqOptions.transformationrrc4|jS)a2 This read-write attribute specifies the transactional behavior of the enqueue request. It should be one of the values :data:`~oracledb.ENQ_ON_COMMIT` (default) or :data:`~oracledb.ENQ_IMMEDIATE`. Note the value of :attr:`~Connection.autocommit` is ignored. rr5s rrzEnqOptions.visibilitysz((***rc:|j|dSrrrs rrzEnqOptions.visibilityrr) rGrHrIrJrrKrrrr.rrrLrrrrs=[  Ac A A AX A,#,$,,,,////X/-C-D----+C+++X+))))))))rrceZdZgZedZedefdZede fdZ e j de ddfdZ edefdZ e j deddfd Z edefd Z edejfd Zede fd Zej de ddfd ZedefdZej deddfdZedefdZedeeeffdZej deddfdZedefdZej deddfdZedee fdZej deddfdZedefdZdS)r c>||}||_|Srr)rrpropss rrzMessageProperties._from_impls C    rr!c4|jS)z This read-only attribute specifies the number of attempts that have been made to dequeue the message. )rget_num_attemptsr5s rattemptszMessageProperties.attemptss z**,,,rc4|jS)zq This read-write attribute specifies the correlation used when the message was enqueued. rr5s rrzMessageProperties.correlations z))+++rrNc:|j|dSrrrs rrzMessageProperties.correlationrrc4|jS)a This read-write attribute specifies the number of seconds to delay an enqueued message. Any integer is acceptable but the constant :data:`~oracledb.MSG_NO_DELAY` can also be used indicating that the message is available for immediate dequeuing. )r get_delayr5s rdelayzMessageProperties.delayz##%%%rc:|j|dSr)r set_delayrs rrzMessageProperties.delays U#####rc4|jS)z This read-only attribute specifies the type of message that was dequeued. It will be one of the values :data:`~oracledb.MSG_PERSISTENT` or :data:`~oracledb.MSG_BUFFERED`. )rget_delivery_moder5s rrzMessageProperties.deliverymode rrc4|jS)zd This read-only attribute specifies the time that the message was enqueued. )r get_enq_timer5s renqtimezMessageProperties.enqtimes z&&(((rc4|jS)a This read-write attribute specifies the name of the queue to which the message is moved if it cannot be processed successfully. Messages are moved if the number of unsuccessful dequeue attempts has exceeded the maximum number of retries or if the message has expired. All messages in the exception queue are in the :data:`~oracledb.MSG_EXPIRED` state. The default value is the name of the exception queue associated with the queue table. )rget_exception_queuer5s r exceptionqzMessageProperties.exceptionqsz--///rc:|j|dSr)rset_exception_queuers rrzMessageProperties.exceptionq+s &&u-----rc4|jS)a This read-write attribute specifies, in seconds, how long the message is available for dequeuing. This attribute is an offset from the delay attribute. Expiration processing requires the queue monitor to be running. Any integer is accepted but the constant :data:`~oracledb.MSG_NO_EXPIRATION` can also be used indicating that the message never expires. )rget_expirationr5s r expirationzMessageProperties.expiration/rrc:|j|dSr)rset_expirationrs rrzMessageProperties.expiration;rrc4|jS)z This read-only attribute specifies the id of the message in the last queue that enqueued or dequeued this message. If the message has never been dequeued or enqueued, the value will be `None`. rr5s rrzMessageProperties.msgid?sz((***rc|jjS)a This read-write attribute specifies the payload that will be enqueued or the payload that was dequeued when using a queue. When enqueuing, the value is checked to ensure that it conforms to the type expected by that queue. For RAW queues, the value can be a bytes object or a string. If the value is a string it will be converted to bytes in the encoding UTF-8. )rr&r5s rr&zMessageProperties.payloadHsz!!rct|tr |j|jnt|tt fs|j|n[t|tr|}nt|t r|}|j|||j_ dSr) r$r rset_payload_objectr.r/set_payload_jsonencodeset_payload_bytesr&)r1r value_bytess rr&zMessageProperties.payloadTs eX & & 6 J ) )%+ 6 6 6 6EC<00 6 J ' ' . . . .%%% $#llnn E5)) $# J ( ( 5 5 5" rc4|jS)z This read-write attribute specifies the priority of the message. A smaller number indicates a higher priority. The priority can be any integer, including negative numbers. The default value is 0. )r get_priorityr5s rpriorityzMessageProperties.prioritybsz&&(((rc:|j|dSr)r set_priorityrs rrzMessageProperties.priorityks &&&&&rc|jS)a0 This read-write attribute specifies a list of recipient names that can be associated with a message at the time a message is enqueued. This allows a limited set of recipients to dequeue each message. The recipient list associated with the message overrides the queue subscriber list, if there is one. The recipient names need not be in the subscriber list but can be, if desired. To dequeue a message, the consumername attribute can be set to one of the recipient names. The original message recipient list is not available on dequeued messages. All recipients have to dequeue a message before it gets removed from the queue. Subscribing to a queue is like subscribing to a magazine: each subscriber can dequeue all the messages placed into a specific queue, just as each magazine subscriber has access to all its articles. Being a recipient, however, is like getting a letter: each recipient is a designated target of a particular message. ) _recipientsr5s r recipientszMessageProperties.recipientsos *rcH|j|||_dSr)rset_recipientsrrs rr zMessageProperties.recipientss& !!%((( rc4|jS)a This read-only attribute specifies the state of the message at the time of the dequeue. It will be one of the values :data:`~oracledb.MSG_WAITING`, :data:`~oracledb.MSG_READY`, :data:`~oracledb.MSG_PROCESSED`, or :data:`~oracledb.MSG_EXPIRED`. )r get_stater5s rstatezMessageProperties.staterr)rGrHrIrrJrrKrrr.rrrrdatetimerrrr/rrr r&rrr-r rrLrrr r snK[ -#---X-,S,,,X,******&s&&&X& \$3$4$$$\$.c...X.)*)))X) 0C 0 0 0X 0...... +C + + +X +))))))+u+++X+ "uh/ " " "X " ^ #S #T # # #^ #)#)))X)_'c'd'''_' DI   X ,!!!!!!&s&&&X&&&rr )rrconnection_moduletypingrrrbaserdbobjectr r r rOrrrr rLrrrs@------,,,,,,,,b!b!b!b!b!-b!b!b!b!JN$N$N$N$N$IN$N$N$b-0-0-0-0-0-0-0-0`Y#Y#Y#Y#Y#=Y#Y#Y#Y#x3)3)3)3)3)=3)3)3)3)lr&r&r&r&r&-r&r&r&r&r&r&r