
    h                     :    S r SSKJr  SSKJr  Sr " S S\5      rg)zAMQP Messages.   )GenericContent)Basic)Messagec                   t   ^  \ rS rSrSr\R                  r/ SQrS	U 4S jjrSr	\
S 5       r\
S 5       rSrU =r$ )
r      a}  A Message for use with the Channel.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: unsigned long
        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})
))content_types)content_encodingr	   )application_headersF)delivery_modeo)priorityr   )correlation_idr	   )reply_tor	   )
expirationr	   )
message_idr	   )	timestampL)typer	   )user_idr	   )app_idr	   )
cluster_idr	   c                 L   > [         TU ]  " S0 UD6  S U l        Xl        X0l        g )N )super__init__delivery_infobodychannel)selfr   childrenr    
properties	__class__s        :D:\TimeStamps\venv\Lib\site-packages\amqp/basic_message.pyr   Message.__init__g   s%    &:&!	    )r   r   r    c                 8    U R                   R                  S5      $ )Nr   )r#   getr!   s    r%   headersMessage.headerst   s    ""#899r'   c                 8    U R                   R                  S5      $ )Ndelivery_tag)r   r)   r*   s    r%   r.   Message.delivery_tagx   s    !!%%n55r'   )r   r    r   ) NN)__name__
__module____qualname____firstlineno____doc__r   CLASS_ID
PROPERTIESr   	__slots__propertyr+   r.   __static_attributes____classcell__)r$   s   @r%   r   r      sO    <| ~~H
J"
I : : 6 6r'   r   N)r5   serializationr   specr   __all__r   r   r'   r%   <module>r?      s#     ) 
h6n h6r'   