Yohohohohohooho | Sanrei Aya
Sanrei Aya


Server : LiteSpeed
System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : elvh3918 ( 1528)
PHP Version : 8.2.31
Disable Function : mail
Directory :  /usr/local/lib/python3.9/site-packages/amqp/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/amqp/__pycache__/basic_message.cpython-39.pyc
a

��Sh
�@s4dZddlmZddlmZdZGdd�de�ZdS)zAMQP Messages.�)�GenericContent)�Basic)�MessagecsLeZdZdZejZgd�Zd�fdd�	ZdZe	dd	��Z
e	d
d��Z�ZS)
raA 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)Z
delivery_mode�o)�priorityr
)Zcorrelation_idr)Zreply_tor)Z
expirationr)Z
message_idr)�	timestamp�L)�typer)Zuser_idr)Zapp_idr)Z
cluster_idr�Ncs(t�jfi|��d|_||_||_dS)N)�super�__init__�
delivery_info�body�channel)�selfr�childrenr�
properties��	__class__��</usr/local/lib/python3.9/site-packages/amqp/basic_message.pyrgszMessage.__init__)rrrcCs|j�d�S)Nr)r�get�rrrr�headerstszMessage.headerscCs|j�d�S)N�delivery_tag)rrrrrrrxszMessage.delivery_tag)rNN)
�__name__�
__module__�__qualname__�__doc__rZCLASS_IDZ
PROPERTIESr�	__slots__�propertyrr�
__classcell__rrrrrs>
rN)r#Z
serializationr�specr�__all__rrrrr�<module>s


Yohohohohohooho | Sanrei Aya