File: //usr/local/lib/python3.9/site-packages/kombu/__pycache__/message.cpython-39.pyc
a
X>h� � @ st d Z ddlmZ ddlZddlmZ ddlmZmZ ddl m
Z
ddl m Z d Z
h d
�Zeed �ZG d d
� d
�ZdS )zMessage class.� )� annotationsN� )�
decompress)�MessageStateError�reraise)�loads)�
dictfilter)�Message> �REQUEUED�ACK�REJECTED�pypy_version_infoc
@ s� e Zd ZdZeZdZes dZd dd�Zd dd�Z d d d
�Z
d d d �Z d!d
d�Z d"dd�Z
dd� Zdd� Zdd� Zedd� �Zedd� �Zdd � ZdS )#r au Base class for received messages.
Keyword Arguments:
-----------------
channel (ChannelT): If message was received, this should be the
channel that the message was received on.
body (str): Message body.
delivery_mode (bool): Set custom delivery mode.
Defaults to :attr:`delivery_mode`.
priority (int): Message priority, 0 to broker configured
max priority, where higher is better.
content_type (str): The messages content_type. If content_type
is set, no serialization occurs as it is assumed this is either
a binary object, or you've done your own serialization.
Leave blank if using built-in serialization as our library
properly sets content_type.
content_encoding (str): The character set in which this object
is encoded. Use "binary" if sending in raw binary objects.
Leave blank if using built-in serialization as our library
properly sets content_encoding.
properties (Dict): Message properties.
headers (Dict): Message headers.
N) �_state�channel� delivery_tag� content_type�content_encoding�
delivery_info�headers�
properties�body�_decoded_cache�accept�__dict__c
K s� |si n|}| j d u rg n| j | _ |
| _|| _|| _|| _|| _|pFi | _|pPi | _d | _d| _ | | _
| j� d�} | j s�| r�zt || �}W n" t
y� | j �t�� � Y n0 | j s�|r�t|t�r�z|�|�}W n" t
y� | j �t�� � Y n0 || _d S )NZRECEIVED� compression)�errorsr r r r r r r r r r �getr � Exception�append�sys�exc_info�
isinstance�str�encoder )
�selfr r r r r r r Z
postencoder r �kwargsr � r& �7/usr/local/lib/python3.9/site-packages/kombu/message.py�__init__> s0
zMessage.__init__c
C sL zt | jd � W n4 tyF } z |s(� || |� W Y d }~n
d }~0 0 d S )Nr )r r r )r$ �callback�excr& r& r' �_reraise_error] s zMessage._reraise_errorFc C s� | j du r| �d��| j jdurRz| jd }W n ty@ Y n0 || j jv rRdS | jrh| �d�| ���| j j| j|d� d| _ dS )z�Acknowledge this message as being processed.
This will remove the message from the queue.
Raises
------
MessageStateError: If the message has already been
acknowledged/requeued/rejected.
N�.This message does not have a receiving channel� consumer_tag�3Message already acknowledged with state: {0._state}��multipler )
r r Zno_ack_consumersr �KeyError� acknowledged�formatZ basic_ackr r )r$ r0 r- r& r& r' �acke s&
� ��z Message.ackc
C s� z| j |d� W np tyJ } z"|jd| j|dd� � W Y d }~n@d }~0 |y� } z |jd| j|dd� W Y d }~n
d }~0 0 d S )Nr/ zCouldn't ack %r, reason:%rT�r )r4 �BrokenPipeError�criticalr )r$ �loggerr r0 r* r& r& r' �
ack_log_error� s ��zMessage.ack_log_errorc
C sN z| j |d� W n8 |yH } z |jd| j|dd� W Y d }~n
d }~0 0 d S )N��requeuez Couldn't reject %r, reason: %rTr5 )�rejectr7 r )r$ r8 r r; r* r& r& r' �reject_log_error� s �zMessage.reject_log_errorc C sF | j du r| �d��| jr*| �d�| ���| j j| j|d� d| _dS )z�Reject this message.
The message will be discarded by the server.
Raises
------
MessageStateError: If the message has already been
acknowledged/requeued/rejected.
Nr, r. r: r �r r r2 r3 Z basic_rejectr r )r$ r; r& r& r' r< � s
���zMessage.rejectc C sF | j du r| �d��| jr*| �d�| ���| j j| jdd� d| _dS )aL Reject this message and put it back on the queue.
Warning:
-------
You must not use this method as a means of selecting messages
to process.
Raises
------
MessageStateError: If the message has already been
acknowledged/requeued/rejected.
Nr, r. Tr: r
r> �r$ r& r& r' r; � s
���zMessage.requeuec C s | j s| �� | _ | j S )z�Deserialize the message body.
Returning the original python structure sent by the publisher.
Note:
----
The return value is memoized, use `_decode` to force
re-evaluation.
)r �_decoder? r& r& r' �decode� s
zMessage.decodec C s t | j| j| j| jd�S )N)r )r r r r r r? r& r& r' r@ � s
�zMessage._decodec C s
| j tv S )z1Set to true if the message has been acknowledged.)r �
ACK_STATESr? r& r& r' r2 � s zMessage.acknowledgedc C s | j r | j S | �� S )zThe decoded message body.)r rA r? r& r& r' �payload� s zMessage.payloadc C sr d� t| �jt| �t| j| j| j| jd ur4t | j�nd t| j
� d�| j
� d�d�t| j � d�| j � d�d�d��S ) Nz&<{} object at {:#x} with details {!r}>�correlation_id�type)rD rE �exchange� routing_key)rF rG )�stater r � body_lengthr r )
r3 rE �__name__�idr r r r r �lenr r r r? r& r& r' �__repr__� s
�
���zMessage.__repr__)
NNNNNNNNNN)N)F)F)F)F)rJ �
__module__� __qualname__�__doc__r r �IS_PYPY� __slots__r( r+ r4 r9 r= r< r; rA r@ �propertyr2 rC rM r& r& r& r' r s. �
r )rP �
__future__r r r r �
exceptionsr r Z
serializationr Zutils.functionalr �__all__rB �hasattrrQ r r& r& r& r' �<module> s