File: //home/arjun/projects/env/lib/python3.10/site-packages/kombu/__pycache__/message.cpython-310.pyc
o
'we� � @ 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> �ACK�REJECTED�REQUEUED�pypy_version_infoc @ s� e Zd ZdZeZdZesdZ d 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 r
g n| j | _ |
| _|| _|| _|| _|| _|p#i | _|p(i | _d | _d| _ | | _
| j� d�} | j sW| rWzt || �}W n t
yV | j �t�� � Y nw | j sz|rzt|t�rzz|�|�}W n t
yy | j �t�� � Y nw || _d S )N�RECEIVED� 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 �
postencoder r �kwargsr � r( �F/home/arjun/projects/env/lib/python3.10/site-packages/kombu/message.py�__init__> s4
� �
zMessage.__init__c
C sL z
t | jd � W d S ty% } z|s� || |� W Y d }~d S d }~ww )Nr )r r r )r% �callback�excr( r( r) �_reraise_error] s ��zMessage._reraise_errorFc C s� | j du r
| �d��| j jdur)z| jd }W n ty Y n w || j jv r)dS | jr4| �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 �no_ack_consumersr �KeyError� acknowledged�format� basic_ackr r )r% r2 r/ r( r( r) �acke s(
� � ��
z Message.ackc
C sz z | j |d� W d S ty } z |jd| j|dd� � d }~w |y< } z|jd| j|dd� W Y d }~d S d }~ww )Nr1 zCouldn't ack %r, reason:%rT�r! )r8 �BrokenPipeError�criticalr )r% �loggerr r2 r, r( r( r) �
ack_log_error� s �����zMessage.ack_log_errorc
C sN z | j |d� W d S |y& } z|jd| j|dd� W Y d }~d S d }~ww )N��requeuez Couldn't reject %r, reason: %rTr9 )�rejectr; r )r% r< 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. r0 r> r �r r r5 r6 � 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. r0 Tr> r rB �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 �_decoderD r( r( r) �decode� s
zMessage.decodec C s t | j| j| j| jd�S )N)r )r r r r r rD r( r( r) rE � s
�zMessage._decodec C s
| j tv S )z1Set to true if the message has been acknowledged.)r �
ACK_STATESrD r( r( r) r5 � s
zMessage.acknowledgedc C s | j r| j S | �� S )zThe decoded message body.)r rF rD r( r( r) �payload� s zMessage.payloadc C sr d� t| �jt| �t| j| j| j| jd urt | 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)rI rJ �exchange� routing_key)rK rL )�stater r � body_lengthr r )
r6 rJ �__name__�idr r r r r �lenr r r rD r( r( r) �__repr__� s
�
���zMessage.__repr__)
NNNNNNNNNN)N)F)rO �
__module__� __qualname__�__doc__r r �IS_PYPY� __slots__r* r- r8 r= rA r@ r? rF rE �propertyr5 rH rR r( r( r( r) r s0
�
r )rU �
__future__r r r r �
exceptionsr r �
serializationr �utils.functionalr �__all__rG �hasattrrV r r( r( r( r) �<module> s