σ O'—^c@@s—dZddlmZddlZddlmZddlmZddlm Z m Z ddl m Z e d d d gƒZd efd „ƒYZdS(sB kombu.transport.message ======================= Message class. i(tabsolute_importNi(t decompress(tMessageStateError(treraisettext_t(tloadstACKtREJECTEDtREQUEUEDtMessagec B@sͺeZdZdZeZdZddddiddddd „ Zdd„Zd„Z d„Z e d„Z e d„Z d„Zd„Zed„ƒZed„ƒZRS(s!Base class for received messages.t_statetchannelt delivery_tagt content_typetcontent_encodingt delivery_infotheaderst propertiestbodyt_decoded_cachetacceptt__dict__c K@sU|jdkrgn|j|_||_||_||_||_||_|pWi|_|pfi|_d|_ d|_ | |_ |jj dƒ} |j rι| rιyt || ƒ}Wqιtk rε|jjtjƒƒqιXn|j rH| rHt|tƒrHy|j| ƒ}WqHtk rD|jjtjƒƒqHXn||_dS(NtRECEIVEDt compression(terrorstNoneR R R RRRRRR RtgetRt Exceptiontappendtsystexc_infot isinstanceRtencodeR( tselfR RR R RRRRt postencodeRtkwargsR((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyt__init__s.!          cC@sHyt|jdŒWn,tk rC}|s3‚n|||ƒnXdS(Ni(RRR(R!tcallbacktexc((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyt_reraise_error<s cC@s”|jjdk rPy|jd}Wntk r6qPX||jjkrPdSn|jrt|jdj|ƒƒ‚n|jj|j ƒd|_ dS(sάAcknowledge this message as being processed., This will remove the message from the queue. :raises MessageStateError: If the message has already been acknowledged/requeued/rejected. t consumer_tagNs3Message already acknowledged with state: {0._state}R( R tno_ack_consumersRRtKeyErrort acknowledgedRtformatt basic_ackR R (R!R(((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pytackDs  cC@sDy|jƒWn/|k r?}|jd|j|dtƒnXdS(NsCouldn't ack %r, reason:%rR(R.tcriticalR tTrue(R!tloggerRR&((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyt ack_log_error[s  cC@sJy|jd|ƒWn/|k rE}|jd|j|dtƒnXdS(NtrequeuesCouldn't reject %r, reason: %rR(trejectR/R R0(R!R1RR3R&((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pytreject_log_errorbs  cC@sJ|jr$|jdj|ƒƒ‚n|jj|jd|ƒd|_dS(sΔReject this message. The message will be discarded by the server. :raises MessageStateError: If the message has already been acknowledged/requeued/rejected. s3Message already acknowledged with state: {0._state}R3RN(R+RR,R t basic_rejectR R (R!R3((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyR4is cC@sJ|jr$|jdj|ƒƒ‚n|jj|jdtƒd|_dS(sReject this message and put it back on the queue. 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. s3Message already acknowledged with state: {0._state}R3RN(R+RR,R R6R R0R (R!((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyR3ys cC@s"t|j|j|jd|jƒS(sdDeserialize the message body, returning the original python structure sent by the publisher.R(RRR RR(R!((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pytdecodeŠscC@s |jtkS(s1Set to true if the message has been acknowledged.(R t ACK_STATES(R!((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyR+scC@s"|js|jƒ|_n|jS(sThe decoded message body.(RR7(R!((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pytpayload•s ( R R R R RRRRRRRRN(t__name__t __module__t__doc__t __slots__RRRR$R'R.R2tFalseR5R4R3R7tpropertyR+R9(((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyR s(          (R<t __future__RRRRt exceptionsRtfiveRRt serializationRt frozensetR8tobjectR (((s//tmp/pip-unpacked-wheel-UAnTfW/kombu/message.pyts