hWdZddlZddlmZddlmZmZddlmZddl m Z dZ hd Z e ed ZGd d ZdS) zMessage class.N) decompress)MessageStateErrorreraise)loads) dictfilter)Message>ACKREJECTEDREQUEUEDpypy_version_infoceZdZdZeZdZesdZ ddZddZ ddZ ddZ dd Z dd Z d Zd Zd ZedZedZdZdS)r a`Base 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|_| |_||_||_||_||_|pi|_|pi|_d|_d|_ | |_ |j d} |jsO| rM t|| }n;#t$r.|jtjYnwxYw|jsi|rgt#|t$rR ||}n;#t$r.|jtjYnwxYw||_dS)NRECEIVED compression)errorsrrrrrrrrrrgetr Exceptionappendsysexc_info isinstancestrencoder) selfrrrrrrr postencoderrkwargsrs I/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/kombu/message.py__init__zMessage.__init__<sw#0B]  K/bbT[  (( 0*}" $*"   l&&}55 { 3{ 3 3!$ 44 3 3 3 ""3<>>22222 3{ 3z 3js.C.C 3 3{{:.. 3 3 3 ""3<>>22222 3 s$ B5CC5D 5EEc~ t|jddS#t$r}|s|||Yd}~dSd}~wwxYw)Nr)rrr )r'callbackexcs r*_reraise_errorzMessage._reraise_error[sl T[^ $ $ $ $     HT3          s <7<Fcb|j|d|jj/ |jd}||jjvrdSn#t$rYnwxYw|jr(|d||j|j|d|_ dS)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'r5r2s r*ackz Message.ackcs < ((@BB B < ( 4 #1.A  4<#@@@FA       ((ELL  t08DDD s A AAc ||dS#t$r$}|d|j|dd}~w|$r)}|d|j|dYd}~dSd}~wwxYw)Nr4zCouldn't ack %r, reason:%rTr#)r;BrokenPipeErrorcriticalr)r'loggerrr5r.s r* ack_log_errorzMessage.ack_log_error~s C HHhH ' ' ' ' '    OO8 -sT  C C C  C C C OO8 -sT  C C C C C C C C C Cs  A4AA4 A//A4c ||dS#|$r)}|d|j|dYd}~dSd}~wwxYw)NrequeuezCouldn't reject %r, reason: %rTr=)rejectr?r)r'r@rrDr.s r*reject_log_errorzMessage.reject_log_errors C KKK ( ( ( ( ( C C C OO< -sT  C C C C C C C C C CsAAAc|j|d|jr(|d||j|j|d|_dS)zReject this message. The message will be discarded by the server. Raises: MessageStateError: If the message has already been acknowledged/requeued/rejected. Nr1r3rCr rrr8r9 basic_rejectrr)r'rDs r*rEzMessage.rejects < ((@BB B   ((ELL  !!$"3W!EEE  c|j|d|jr(|d||j|jdd|_dS)a.Reject 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. Nr1r3TrCr rHr's r*rDzMessage.requeues < ((@BB B   ((ELL  !!$"3T!BBB  rJcP|js||_|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_decoderLs r*decodezMessage.decodes(" 1"&,,..D ""rJcPt|j|j|j|jS)N)r)rrrrrrLs r*rNzMessage._decodes0TY 1*4;@@@ @rJc|jtvS)z1Set to true if the message has been acknowledged.)r ACK_STATESrLs r*r8zMessage.acknowledgeds{j((rJcF|jr|jn|S)zThe decoded message body.)rrOrLs r*payloadzMessage.payloads"'+&9Lt""t{{}}LrJcdt|jt|t |j|j|j|jt|jndt |j d|j dt |j d|j dS) Nz&<{} object at {:#x} with details {!r}>correlation_idtype)rVrWexchange routing_key)rXrY)staterr body_lengthrr) r9rW__name__idrrrrrlenrrrrLs r*__repr__zMessage.__repr__s7>> JJ D:k!.!..2i.CC NNN%#'?#6#67G#H#H,,V44)!/33J?? $ 2 6 6} E E , , ,   rJ) NNNNNNNNNN)N)F)r\ __module__ __qualname____doc__rrIS_PYPY __slots__r+r/r;rArFrErDrOrNpropertyr8rTr_rJr*r r s@>* F   04IM;?&*>    6 C C C CCCCC!!!!&!!!* # # #@@@))X)MMXM     rJr )rbr"rr exceptionsrr serializationrutils.functionalr__all__rRhasattrrcr rfrJr*rls ######22222222 ((((((  , , , '#* + +S S S S S S S S S S rJ