ó O'—^c@@sIdZddlmZddlmZdgZdefd„ƒYZdS(sMessages for AMQPi(tabsolute_importi(tGenericContenttMessagecB@sYeZdZdddddddddddd d!d"gZdd#d#d„Zd„ZRS($s4A Message for use with the Channnel.basic_* methods.t content_typetshortstrtcontent_encodingtapplication_headersttablet delivery_modetoctettprioritytcorrelation_idtreply_tot expirationt message_idt timestampttypetuser_idtapp_idt cluster_idtcK@s,tt|ƒj|||_||_dS(smExpected arg types body: string children: (not supported) Keyword properties may include: content_type: shortstr MIME content type content_encoding: shortstr MIME content encoding application_headers: table Message header field table, a dict with string keys, and string | int | Decimal | datetime | dict values. delivery_mode: octet Non-persistent (1) or persistent (2) priority: octet The message priority, 0 to 9 correlation_id: shortstr The application correlation identifier reply_to: shortstr The destination to reply to expiration: shortstr Message expiration specification message_id: shortstr The application message identifier timestamp: datetime.datetime The message timestamp type: shortstr The message type name user_id: shortstr The creating user id app_id: shortstr The creating application id cluster_id: shortstr Intra-cluster routing identifier Unicode bodies are encoded according to the 'content_encoding' argument. If that's None, it's set to 'UTF-8' automatically. example:: msg = Message('hello world', content_type='text/plain', application_headers={'foo': 7}) N(tsuperRt__init__tbodytchannel(tselfRtchildrenRt properties((s4/tmp/pip-unpacked-wheel-9igm28/amqp/basic_message.pyR/s= cC@sEy,tt|ƒj|ƒo*|j|jkSWntk r@tSXdS(sÈCheck if the properties and bodies of this Message and another Message are the same. Received messages may contain a 'delivery_info' attribute, which isn't compared. N(RRt__eq__RtAttributeErrortNotImplemented(Rtother((s4/tmp/pip-unpacked-wheel-9igm28/amqp/basic_message.pyRps  (RR(RR(RR(RR (R R (R R(R R(R R(RR(RR(RR(RR(RR(RRN(t__name__t __module__t__doc__t PROPERTIEStNoneRR(((s4/tmp/pip-unpacked-wheel-9igm28/amqp/basic_message.pyRs" AN(R"t __future__Rt serializationRt__all__R(((s4/tmp/pip-unpacked-wheel-9igm28/amqp/basic_message.pyts