U .e@svdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z d Z d d d hZeed ZGdddZdS)zMessage class.) annotationsN) decompress)MessageStateErrorreraise)loads) dictfilter)MessageACKREJECTEDREQUEUEDpypy_version_infoc @seZdZdZeZdZesdZdddZdddZ dd d Z d d d Z d!d dZ d"ddZ 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|}|jdkrgn|j|_| |_||_||_||_||_|pFi|_|pPi|_d|_d|_ | |_ |j d} |js| rzt || }Wn$t k r|jtYnX|js|rt|trz||}Wn$t k r|jtYnX||_dS)NZRECEIVED compression)errorsrrrrrrrrrrgetr Exceptionappendsysexc_info isinstancestrencoder) selfrrrrrrrZ postencoderrkwargsrr&1/tmp/pip-unpacked-wheel-48hrr5dg/kombu/message.py__init__>s0     zMessage.__init__c CsJzt|jdWn2tk rD}z|s*|||W5d}~XYnXdS)Nr)rrr)r$callbackexcr&r&r'_reraise_error]s zMessage._reraise_errorFcCs|jdkr|d|jjdk rTz|jd}Wntk rBYnX||jjkrTdS|jrj|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$r0r-r&r&r'ackes&   z Message.ackc Csz|j|dWnltk rH}z|jd|j|ddW5d}~XYn6|k r|}z|jd|j|ddW5d}~XYnXdS)Nr/zCouldn't ack %r, reason:%rTr )r4BrokenPipeErrorcriticalr)r$loggerrr0r*r&r&r' ack_log_errorszMessage.ack_log_errorc CsLz|j|dWn6|k rF}z|jd|j|ddW5d}~XYnXdS)NrequeuezCouldn't reject %r, reason: %rTr5)rejectr7r)r$r8rr;r*r&r&r'reject_log_errorszMessage.reject_log_errorcCsF|jdkr|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.r:r rrr2r3Z basic_rejectrr)r$r;r&r&r'r<s zMessage.rejectcCsF|jdkr|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,r.Tr:r 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 |jtkS)z1Set to true if the message has been acknowledged.)r ACK_STATESr?r&r&r'r2szMessage.acknowledgedcCs|jr |jS|S)zThe decoded message body.)rrAr?r&r&r'payloadszMessage.payloadcCsrdt|jt|t|j|j|j|jdk r4t |jndt|j d|j ddt|j d|j dddS) Nz&<{} object at {:#x} with details {!r}>correlation_idtype)rDrEexchange routing_key)rFrG)staterr body_lengthrr) r3rE__name__idrrrrrlenrrrr?r&r&r'__repr__s$    zMessage.__repr__) NNNNNNNNNN)N)F)F)F)F)rJ __module__ __qualname____doc__rrIS_PYPY __slots__r(r+r4r9r=r<r;rAr@propertyr2rCrMr&r&r&r'r s8       r )rP __future__rrrr exceptionsrrZ serializationrZutils.functionalr__all__rBhasattrrQr r&r&r&r's