o h @s4dZddlmZddlmZdZGdddeZdS)zAMQP Messages.)GenericContent)Basic)MessagecsLeZdZdZejZgdZd 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_types)content_encodingr)application_headersF) delivery_modeo)priorityr )correlation_idr)reply_tor) expirationr) message_idr) timestampL)typer)user_idr)app_idr) cluster_idrNc s(tjdi|d|_||_||_dS)N)super__init__ delivery_infobodychannel)selfrchildrenr properties __class__rT/var/www/html/optinet_system/venv/lib/python3.10/site-packages/amqp/basic_message.pyrgs zMessage.__init__)rrrcC |jdS)Nr)r getrrrr#headerst zMessage.headerscCr$)N delivery_tag)rr%r&rrr#r)xr(zMessage.delivery_tag)rNN) __name__ __module__ __qualname____doc__rCLASS_ID PROPERTIESr __slots__propertyr'r) __classcell__rrr!r#rs> rN)r- serializationrspecr__all__rrrrr#s