Ë
    šQj  ã                   ó:   — d Z ddlmZ ddlmZ dZ G d„ de«      Zy)zAMQP Messages.é   )ÚGenericContent)ÚBasic)ÚMessagec                   óh   ‡ — e Zd ZdZej
                  Zg d¢Zdˆ fd„	ZdZe	d„ «       Z
e	d„ «       Zˆ xZS )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                 óN   •— t        ‰| �  di |¤Ž d | _        || _        || _        y )N© )ÚsuperÚ__init__Údelivery_infoÚbodyÚchannel)Úselfr   Úchildrenr   Ú
propertiesÚ	__class__s        €úN/var/www/html/truck-me/venv/lib/python3.12/site-packages/amqp/basic_message.pyr   zMessage.__init__g   s)   ø€ Ü‰ÑÑ&˜:Ò&à!ˆÔØˆŒ	Øˆ�ó    )r   r   r   c                 ó8   — | j                   j                  d«      S )Nr
   )r"   Úget©r    s    r$   ÚheaderszMessage.headerst   s   € à�‰×"Ñ"Ð#8Ó9Ð9r%   c                 ó8   — | j                   j                  d«      S )NÚdelivery_tag)r   r'   r(   s    r$   r+   zMessage.delivery_tagx   s   € à×!Ñ!×%Ñ% nÓ5Ð5r%   )Ú NN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   ÚCLASS_IDÚ
PROPERTIESr   Ú	__slots__Úpropertyr)   r+   Ú__classcell__)r#   s   @r$   r   r      sO   ø„ ñ<ð| �~‰~€Hò
€Jõ"ð
€Ið ñ:ó ð:ð ñ6ó ô6r%   r   N)r0   Úserializationr   Úspecr   Ú__all__r   r   r%   r$   ú<module>r9      s#   ðÙ å )õ à
€ôh6ˆnõ h6r%   