a xdW@shdZddlZddlmZddlmZmZddlmZddl m Z dZ hd Z e ed ZGd d d ZdS) zMessage class.N) decompress)MessageStateErrorreraise)loads) dictfilter)Message>ACKREQUEUEDREJECTEDpypy_version_infoc @seZdZdZeZdZesdZdddZdddZ dd d Z d d d Z d!d dZ d"ddZ ddZddZddZeddZeddZddZdS)#ra`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 Ks|sin|}|jdurgn|j|_| |_||_||_||_||_|pFi|_|pPi|_d|_d|_ | |_ |j d} |js| rzt || }Wn"t y|jtYn0|js|rt|trz||}Wn"t y|jtYn0||_dS)NZRECEIVED compression)errorsrrrrrrrrr rgetr Exceptionappendsysexc_info isinstancestrencoder) selfrrrrrrrZ postencoderrkwargsrr%E/var/www/html/Ranjet/env/lib/python3.9/site-packages/kombu/message.py__init__<s0       zMessage.__init__c CsLzt|jdWn4tyF}z|s(|||WYd}~n d}~00dS)Nr)rrr)r#callbackexcr%r%r&_reraise_error[s zMessage._reraise_errorFcCs|jdur|d|jjdurRz|jd}Wnty@Yn0||jjvrRdS|jrh|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 ) rrZno_ack_consumersrKeyError acknowledgedformatZ basic_ackrr )r#r/r,r%r%r&ackcs&    z Message.ackc Csz|j|dWnptyJ}z"|jd|j|ddWYd}~n@d}~0|y}z |jd|j|ddWYd}~n d}~00dS)Nr.zCouldn't ack %r, reason:%rTr)r3BrokenPipeErrorcriticalr)r#loggerrr/r)r%r%r& ack_log_error~szMessage.ack_log_errorc CsNz|j|dWn8|yH}z |jd|j|ddWYd}~n d}~00dS)NrequeuezCouldn't reject %r, reason: %rTr4)rejectr6r)r#r7rr:r)r%r%r&reject_log_errors zMessage.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+r-r9r rrr1r2Z basic_rejectrr )r#r:r%r%r&r;s zMessage.rejectcCsF|jdur|d|jr*|d||jj|jddd|_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. Nr+r-Tr9r r=r#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_decoder>r%r%r&decodes  zMessage.decodecCst|j|j|j|jdS)N)r)rrrrrr>r%r%r&r?s zMessage._decodecCs |jtvS)z1Set to true if the message has been acknowledged.)r ACK_STATESr>r%r%r&r1szMessage.acknowledgedcCs|jr |jS|S)zThe decoded message body.)rr@r>r%r%r&payloadszMessage.payloadcCsrdt|jt|t|j|j|j|jdur4t |jndt|j d|j ddt|j d|j dddS) Nz&<{} object at {:#x} with details {!r}>correlation_idtype)rCrDexchange routing_key)rErF)staterr body_lengthrr) r2rD__name__idrr rrrlenrrrr>r%r%r&__repr__s     zMessage.__repr__) NNNNNNNNNN)N)F)F)F)F)rI __module__ __qualname____doc__rrIS_PYPY __slots__r'r*r3r8r<r;r:r@r?propertyr1rBrLr%r%r%r&rs.        r)rOrrr exceptionsrrZ serializationrZutils.functionalr__all__rAhasattrrPrr%r%r%r&s