o Df@stdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z d Z hd Zeed ZGd d d ZdS)zMessage class.) annotationsN) decompress)MessageStateErrorreraise)loads) dictfilter)Message>ACKREJECTEDREQUEUEDpypy_version_infoc@seZdZdZeZdZesdZ    dddZdddZ dd d Z dd d Z dd dZ dddZ ddZddZddZeddZeddZddZdS) 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 Ks|sin|}|jdur gn|j|_| |_||_||_||_||_|p#i|_|p(i|_d|_d|_ | |_ |j d} |jsW| rWzt || }Wnt yV|jtYnw|jsz|rzt|trzz||}Wnt yy|jtYnw||_dS)NRECEIVED compression)errorsrrrrrrrrrrgetr Exceptionappendsysexc_info isinstancestrencoder) selfrrrrrrr postencoderrkwargsrr(F/home/ubuntu/webapp/venv/lib/python3.10/site-packages/kombu/message.py__init__>s4        zMessage.__init__c CsLz t|jdWdSty%}z|s|||WYd}~dSd}~ww)Nr)rrr)r%callbackexcr(r(r)_reraise_error]szMessage._reraise_errorFcCs|jdur |d|jjdur)z|jd}Wn ty Yn w||jjvr)dS|jr4|d||jj|j|dd|_ 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%r2r/r(r(r)ackes(     z Message.ackc Cszz |j|dWdSty }z |jd|j|ddd}~w|y<}z|jd|j|ddWYd}~dSd}~ww)Nr1zCouldn't ack %r, reason:%rTr!)r8BrokenPipeErrorcriticalr)r%loggerrr2r,r(r(r) ack_log_errorszMessage.ack_log_errorc CsNz |j|dWdS|y&}z|jd|j|ddWYd}~dSd}~ww)NrequeuezCouldn't reject %r, reason: %rTr9)rejectr;r)r%r<rr?r,r(r(r)reject_log_errorszMessage.reject_log_errorcCsF|jdur |d|jr|d||jj|j|dd|_dS)zReject this message. The message will be discarded by the server. Raises ------ MessageStateError: If the message has already been acknowledged/requeued/rejected. Nr.r0r>r rrr5r6 basic_rejectrr)r%r?r(r(r)r@s  zMessage.rejectcCsF|jdur |d|jr|d||jj|jddd|_dS)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. Nr.r0Tr>r rBr%r(r(r)r?s  zMessage.requeuecCs|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_decoderDr(r(r)decodes zMessage.decodecCst|j|j|j|jdS)N)r)rrrrrrDr(r(r)rEs zMessage._decodecCs |jtvS)z1Set to true if the message has been acknowledged.)r ACK_STATESrDr(r(r)r5s zMessage.acknowledgedcCs|jr|jS|S)zThe decoded message body.)rrFrDr(r(r)payloadszMessage.payloadcCsrdt|jt|t|j|j|j|jdurt |jndt|j d|j ddt|j d|j dddS) Nz&<{} object at {:#x} with details {!r}>correlation_idtype)rIrJexchange routing_key)rKrL)staterr body_lengthrr) r6rJ__name__idrrrrrlenrrrrDr(r(r)__repr__s     zMessage.__repr__) NNNNNNNNNN)N)F)rO __module__ __qualname____doc__rrIS_PYPY __slots__r*r-r8r=rAr@r?rFrEpropertyr5rHrRr(r(r(r)r s0       r )rU __future__rr rr exceptionsrr serializationrutils.functionalr__all__rGhasattrrVr r(r(r(r)s