Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/message.cpython-39.pyc
Ðазад
a o�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> �REJECTED�ACK�REQUEUED�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& �}/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка