Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/simple.cpython-39.pyc
Ðазад
a o�h� � @ s� d Z ddlmZ ddlZddlmZ ddlmZ ddlm Z ddl m Z dd l m Z mZ dd lmZ e rtdd lmZ d ZG d d� d�ZG dd� de�ZG dd� de�ZdS )zSimple messaging interface.� )� annotationsN)�deque)�Empty)� monotonic)� TYPE_CHECKING� )�entity� messaging)� maybe_channel)� TracebackType)� SimpleQueue� SimpleBufferc @ s� e Zd ZeZdZdd� Zddddd�d d �Zd#d d �Zd$dd�Zdd� Z d%dd�Z dd� Z dd� Z dd� Z dd � Zd d � Zd d � Zd!d"� ZeZdS )&� SimpleBaseFc C s | S �N� ��selfr r �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/simple.py� __enter__ s zSimpleBase.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | None�None)�exc_type�exc_val�exc_tb�returnc C s | � � d S r )�close)r r r r r r r �__exit__ s zSimpleBase.__exit__c C sD t |�| _|| _|| _|| _| jjd | _t� | _| j� | j � d S )Nr ) r �channel�producer�consumer�no_ackZqueues�queuer �bufferZregister_callback�_receive)r r r r r r r r �__init__# s zSimpleBase.__init__TNc C s� |s | � � S | �� t� }|}| jr.| j�� S |d urF|dkrF| �� �z| jjjj |d� W n t j yx | �� �Y n0 |d ur t� | }|| }q d S )Ng )�timeout) � get_nowait�_consumer r! �popleftr r � connection�clientZ drain_events�socketr$ )r �blockr$ Z time_start� remaining�elapsedr r r �get, s zSimpleBase.getc C s& | j j| j| jjd�}|s"| �� �|S )N)r �accept)r r. r r r/ r )r �mr r r r% N s zSimpleBase.get_nowaitc K s" | j j|f||||d�|�� d S )N)� serializer� routing_key�headers� compression)r �publish)r �messager1 r3 r4 r2 �kwargsr r r �putT s ��zSimpleBase.putc C s | j �� S r )r �purger r r r �clear] s zSimpleBase.clearc C s | j jdd�\}}}|S )NT)Zpassive)r Z queue_declare)r �_�sizer r r �qsize` s zSimpleBase.qsizec C s | j �� d S r )r �cancelr r r r r d s zSimpleBase.closec C s | j �|� d S r )r! �append)r Z message_datar6 r r r r" g s zSimpleBase._receivec C s | j s | jj| jd� d| _ d S )N)r T)� _consumingr �consumer r r r r r& j s zSimpleBase._consumec C s | � � S )z `len(self) -> self.qsize()`.)r= r r r r �__len__o s zSimpleBase.__len__c C s dS )NTr r r r r �__bool__s s zSimpleBase.__bool__)F)TN)NNNN)�__name__� __module__� __qualname__r r@ r r r# r. r% r8 r: r= r r" r& rB rC � __nonzero__r r r r r s$ " � r c s6 e Zd ZdZdZi Zi ZddiZd� fdd� Z� Z S ) r z!Simple API for persistent queues.F�type�directNc s� |} t | jfi |pi ��}t | jfi |p*i ��}t | jfi |p@i ��}|d u rT| j}t| tj�s�tj|fi |��} tj|| |fd|i|��} |} n | j } | j } t j || | d�} t j || || |d�}t� �||| |� d S )NZqueue_arguments)r/ )r1 r2 r4 )�dict� queue_opts� queue_args� exchange_optsr � isinstancer �QueueZExchange�exchanger2 r ZConsumerZProducer�superr# )r r �namer rK rL rM r1 r4 r/ r rP r2 r r �� __class__r r r# � s2 ��� �zSimpleQueue.__init__)NNNNNNN) rD rE rF �__doc__r rK rL rM r# � __classcell__r r rS r r x s �r c @ s* e Zd ZdZdZddd�Zdddd�ZdS )r z Simple API for ephemeral queues.TF)�durable� auto_delete� transient)rW Z delivery_moderX N)rD rE rF rU r rK rM r r r r r � s ��r )rU � __future__r r* � collectionsr r r �timer �typingr � r r r( r �typesr �__all__r r r r r r r �<module> s d#
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка