ó
õEYc@@s_dZd
dl
mZmZ
ddlmZ
ddlmZ
dg
Zdef
d„ƒYZ	d	S(
uAMQP Messages.i(tabsolute_importtunicode_literalsi
(
tBasic(
tGenericContentuMessagetMessagecB@s}eZ
dZejZdddddddddd d!d"d#d$gZd%Zdd%d%d„Ze	d„ƒ
Z
e	d„ƒ
ZRS(&u"A Message for use with the Channnel.basic_* methods.

    Expected 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})
    ucontent_typeu
sucontent_encodinguapplication_headersu
Fu
delivery_modeu
oupriorityucorrelation_idureply_tou
expirationu
message_idu	timestampu
Lutypeuuser_iduapp_idu
cluster_iducK@s,tt
|ƒj|
|
|_||_dS(
N(tsuperRt__init__tbodytchannel(tselfRtchildrenRt
properties((sG/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/basic_message.pyRzs

	
c

C@s|jj
d
ƒ
S(Nuapplication_headers(Rtget(
R	((sG/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/basic_message.pytheaderssc

C@s|jj
d
ƒ
S(Nudelivery_tag(t
delivery_infoR(
R	((sG/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/basic_message.pytdelivery_tagƒs(ucontent_typeu
s(ucontent_encodingu
s(uapplication_headersu
F(u
delivery_modeu
o(upriorityu
o(ucorrelation_idu
s(ureply_tou
s(u
expirationu
s(u
message_idu
s(u	timestampu
L(utypeu
s(uuser_idu
s(uapp_idu
s(u
cluster_idu
sN(t__name__t
__module__t__doc__RtCLASS_IDt
PROPERTIEStNoneRRtpropertyR
R(((sG/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/basic_message.pyR"s(=	












	N(
Rt
__future__RR
tspecRt
serializationRt__all__R(((sG/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/basic_message.pyt<module>
s