Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/amqp/__pycache__/abstract_channel.cpython-39.pyc
Ðазад
a k�hM � @ s` d Z ddlZddlmZmZ ddlmZmZ ddlm Z m Z dZ e� d�Z d ZG d d � d �ZdS ) z.Code common to Connection and Channel objects.� N)�ensure_promise�promise� )�AMQPNotImplementedError�RecoverableConnectionError)�dumps�loads)�AbstractChannelZamqpzIReceived method %s during closing channel %s. This method will be ignoredc @ sT e Zd ZdZdd� ZdZdd� Zdd� Zdd d �Zd d� Z ddd�Z dd� Z i Z d S )r a Superclass for Connection and Channel. The connection is treated as channel 0, then comes user-created channel objects. The subclasses must have a _METHOD_MAP class property, mapping between AMQP method signatures and Python methods. c C s@ d| _ || _|| _| |j|< g | _d| _i | _i | _| �� d S )NF) � is_closing� connection� channel_idZchannels� method_queue� auto_decode�_pending� _callbacksZ_setup_listeners)�selfr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/amqp/abstract_channel.py�__init__ s zAbstractChannel.__init__) r r r r r r r �__dict__� __weakref__c C s | S �Nr �r r r r � __enter__7 s zAbstractChannel.__enter__c G s | � � d S r )�close)r �exc_infor r r �__exit__: s zAbstractChannel.__exit__NFc C s� t � }| j} | d u r td��|r*t||�nd}z| �d| j|||� W n ty` td��Y n0 |rp|�|� |� |r�| j||d�S |S )Nzconnection already closed� r )� returns_tuple) r r r r Z frame_writerr � StopIterationZthen�wait) r �sig�format�args�contentr �callbackr �p�connr r r � send_method= s zAbstractChannel.send_methodc C s t d��dS )z!Close this Channel or Connection.z Must be overridden in subclassN)�NotImplementedErrorr r r r r R s zAbstractChannel.closec C sD t |�}| j}g }t|t�s"|g}|D ] }|�|�|�� |||< q&z�|js\| jj|d� qF|j r�|j \} } | dd � } |r�| n | o�| d W t |�D ].\} }|| d ur�|| ||< q�|� |d � q�S W t |�D ].\} }|| d ur�|| ||< q�|� |d � q�n>t |�D ]2\} }|| d u�r.|| ||< n |� |d � �q 0 d S )N)�timeoutr r ) r r � isinstance�list�append�get�readyr Z drain_events�value� enumerate�pop) r �methodr% r* r r& �pendingZprev_p�mr# �kwargs�ir r r r V s8 � �zAbstractChannel.waitc C sH | j r$|| jvr$t�t|| j� d S |r`| jr`t|d�r`z|j� |j �|_W n t y^ Y n0 z| j | }W n t y� td|����Y n0 z| j| g}W n t y� g }Y n0 d }z| j�|�}W n t y� |s�Y d S Y n0 g }|j�rt|j|d�\}}|j�r|�|� |D ]} | |� �q |�rD||g|�R � d S )N�content_encodingzUnknown AMQP method � )r Z _ALLOWED_METHODS_WHEN_CLOSING� AMQP_LOGGER�warning�#IGNORED_METHOD_DURING_CHANNEL_CLOSEr r �hasattr�body�decoder8 � Exception�_METHODS�KeyErrorr r r r2 r# r r$ r- ) r Z method_sig�payloadr$ Z amqp_methodZ listenersZone_shotr# �_Zlistenerr r r �dispatch_methodp sT ���� � z AbstractChannel.dispatch_method)NNNNNF)NNF) �__name__� __module__� __qualname__�__doc__r � __slots__r r r( r r rE rA r r r r r s � 3r )rI �loggingZviner r � exceptionsr r Z serializationr r �__all__� getLoggerr: r< r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка