File: //usr/local/lib/python3.9/site-packages/kombu/__pycache__/simple.cpython-39.pyc
a
X>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 �6/usr/local/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_ack�queues�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 r0 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 �messager2 r4 r5 r3 �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_datar7 r r r r# g s zSimpleBase._receivec C s | j s | jj| jd� d| _ d S )N)r T)�
_consumingr Zconsumer 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 rA r r r$ r/ r& r9 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)r0 )r2 r3 r5 )�dict�
queue_opts�
queue_args�
exchange_optsr �
isinstancer �QueueZExchange�exchanger3 r ZConsumerZProducer�superr$ )r r �namer rK rL rM r2 r5 r0 r! rP r3 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_deleteZ 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#