IhdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z d Z hd Zeed ZGd d Zy)zMessage class.) annotationsN) decompress)MessageStateErrorreraise)loads) dictfilter)Message>ACKREJECTEDREQUEUEDpypy_version_infoceZdZdZeZdZesdZ ddZddZ ddZ ddZ ddZ dd Z d Zd Zd Zed ZedZdZy)r auBase class for received messages. Keyword Arguments: ----------------- channel (ChannelT): If message was received, this should be the channel that the message was received on. body (str): Message body. delivery_mode (bool): Set custom delivery mode. Defaults to :attr:`delivery_mode`. priority (int): Message priority, 0 to broker configured max priority, where higher is better. content_type (str): The messages content_type. If content_type is set, no serialization occurs as it is assumed this is either a binary object, or you've done your own serialization. Leave blank if using built-in serialization as our library properly sets content_type. content_encoding (str): The character set in which this object is encoded. Use "binary" if sending in raw binary objects. Leave blank if using built-in serialization as our library properly sets content_encoding. properties (Dict): Message properties. headers (Dict): Message headers. N) _statechannel delivery_tag content_typecontent_encoding delivery_infoheaders propertiesbody_decoded_cacheaccept__dict__c  |sin|}|jgn |j|_| |_||_||_||_||_|xsi|_|xsi|_d|_d|_ | |_ |j jd} |js| r t|| }|js,|r*t#|t$r |j'|}||_y||_y#t$r0|jjtj YxwxYw#t$r7|jjtj Y||_ywxYw)NRECEIVED compression)errorsrrrrrrrrrrgetr Exceptionappendsysexc_info isinstancestrencoder) selfrrrrrrr postencoderrkwargsrs F/var/www/html/planif/env/lib/python3.12/site-packages/kombu/message.py__init__zMessage.__init__>s3#0]  KK/bT[[  (( 0*}" $*"   ll&&}5 {{{ 3!$ 4{{zjs.C 3{{:. D  3 ""3<<>2 3  3 ""3<<>2  3s$ C* D&*6D#"D#&6E&%E&ct t|jdy#t$r}|s|||Yd}~yd}~wwxYw)Nr)rrr!)r(callbackexcs r+_reraise_errorzMessage._reraise_error]s: T[[^ $  T3   s 7 27c|j|jd|jj) |jd}||jjvry|j r |jdj ||jj|j|d|_ y#t$rYfwxYw)zAcknowledge this message as being processed. This will remove the message from the queue. Raises ------ MessageStateError: If the message has already been acknowledged/requeued/rejected. N.This message does not have a receiving channel consumer_tag3Message already acknowledged with state: {0._state}multipler ) rrno_ack_consumersrKeyError acknowledgedformat basic_ackrr)r(r6r3s r+ackz Message.ackes << ((@B B << ( ( 4 #11.A  4<<#@#@@   ((ELL  t008D   sB88 CCc |j|y#t$r%}|jd|j|dd}~w|$r)}|jd|j|dYd}~yd}~wwxYw)Nr5zCouldn't ack %r, reason:%rTr$)r<BrokenPipeErrorcriticalr)r(loggerrr6r/s r+ ack_log_errorzMessage.ack_log_errors~ C HHhH '  OO8 --sT  C  C OO8 --sT  C C Cs A/ >A/A**A/c |j|y#|$r)}|jd|j|dYd}~yd}~wwxYw)NrequeuezCouldn't reject %r, reason: %rTr>)rejectr@r)r(rArrEr/s r+reject_log_errorzMessage.reject_log_errorsP C KKK ( C OO< --sT  C C CsA>Ac|j|jd|jr |jdj||jj |j |d|_y)zReject this message. The message will be discarded by the server. Raises ------ MessageStateError: If the message has already been acknowledged/requeued/rejected. Nr2r4rDr rrr9r: basic_rejectrr)r(rEs r+rFzMessage.rejectsy << ((@B B   ((ELL  !!$"3"3W!E  c|j|jd|jr |jdj||jj |j dd|_y)aLReject this message and put it back on the queue. Warning: ------- You must not use this method as a means of selecting messages to process. Raises ------ MessageStateError: If the message has already been acknowledged/requeued/rejected. Nr2r4TrDr rIr(s r+rEzMessage.requeuesy << ((@B B   ((ELL  !!$"3"3T!B  rKc\|js|j|_|jS)zDeserialize the message body. Returning the original python structure sent by the publisher. Note: ---- The return value is memoized, use `_decode` to force re-evaluation. )r_decoderMs r+decodezMessage.decodes'"""&,,.D """rKcpt|j|j|j|jS)N)r)rrrrrrMs r+rOzMessage._decodes.TYY 1 1**4;;@ @rKc&|jtvS)z1Set to true if the message has been acknowledged.)r ACK_STATESrMs r+r9zMessage.acknowledgeds{{j((rKcR|jr |jS|jS)zThe decoded message body.)rrPrMs r+payloadzMessage.payloads#'+&9&9t""Lt{{}LrKcdjt|jt|t |j |j |j|jt|jndt |jjd|jjdt |jjd|jjdS) Nz&<{} object at {:#x} with details {!r}>correlation_idtype)rWrXexchange routing_key)rYrZ)staterr body_lengthrr) r:rX__name__idr rrrrlenrr rrMs r+__repr__zMessage.__repr__s7>> J  D:kk!..!...2ii.CC N%#'??#6#67G#H,,V4)!//33J? $ 2 2 6 6} E ,  rK) NNNNNNNNNN)N)F)r] __module__ __qualname____doc__rrIS_PYPY __slots__r,r0r<rBrGrFrErPrOpropertyr9rUr`rKr+r r s>* F  04IM;?&*> 8 CC!(!. #@))MM rKr )rc __future__rr#rr exceptionsrr serializationrutils.functionalr __all__rShasattrrdr rgrKr+rns=" #2 (  , #* +X X rK