File: //home/arjun/projects/env/lib/python3.10/site-packages/kombu/__pycache__/simple.cpython-310.pyc
o
'we� � @ s� d Z ddlmZ ddlZddlmZ ddlmZ ddlm Z ddl
m Z dd l m
Z
mZ dd
lmZ e r:dd 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� Zd&d d
�Zd'dd�Zd(dd�Zdd� Z d)dd�Z
dd� Z dd� Z d d � Z
d d � Zd d!� Zd"d#� Zd$d%� ZeZdS )*�
SimpleBaseFc C s | S �N� ��selfr r �E/home/arjun/projects/env/lib/python3.10/site-packages/kombu/simple.py� __enter__ � zSimpleBase.__enter__�exc_type�type[BaseException] | None�exc_val�BaseException | None�exc_tb�TracebackType | None�return�Nonec 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 �buffer�register_callback�_receive)r r r! r" r# r r r �__init__# s
zSimpleBase.__init__TNc C s� |s| � � S | �� t� }|} | jr| j�� S |d ur$|dkr$| �� �z | jjjj |d� W n t
j y; | �� �w |d urIt� | }|| }q)NTg )�timeout) �
get_nowait�_consumer r& �popleftr r �
connection�client� drain_events�socketr* )r �blockr* �
time_start� remaining�elapsedr r r �get, s&
�
�zSimpleBase.getc C s& | j j| j| jjd�}|s| �� �|S )N)r# �accept)r% r6 r# r" r7 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 �messager9 r; r< r: �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)�passive)r% �
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 � message_datar> r r r r( g s zSimpleBase._receivec C s$ | j s| jj| jd� d| _ d S d S )N)r# T)�
_consumingr" �consumer# r r r r r, j s
�zSimpleBase._consumec C s | � � S )z `len(self) -> self.qsize()`.)rG r r r r �__len__o s zSimpleBase.__len__c C s dS )NTr r r r r �__bool__s r zSimpleBase.__bool__)r r r r r r r r )F)TN)NNNN)�__name__�
__module__� __qualname__r rK r r r) r6 r+ r@ rB rG r r( r, rM rN � __nonzero__r r r r r s&
"
� r c s< e Zd ZdZdZi Zi ZddiZ d� fdd� Z� Z S ) r z!Simple API for persistent queues.F�type�directNc
s� |}
t | jfi |p
i ��}t | jfi |pi ��}t | jfi |p i ��}|d u r*| j}t|
tj�sItj|fi |��} tj|| |fd|i|��}
|} n|
j } |
j
} t j ||
| d�}
t j
|| || |d�}t� �|||
|� d S )N�queue_arguments)r7 )r9 r: r< )�dict�
queue_opts�
queue_args�
exchange_optsr# �
isinstancer �Queue�Exchange�exchanger: r �Consumer�Producer�superr) )r r �namer# rW rX rY r9 r< r7 r% r] r: r" r! �� __class__r r r) � s2 ���
�zSimpleQueue.__init__)NNNNNNN)
rO rP rQ �__doc__r# rW rX rY r) �
__classcell__r r rb r r x s �r c @ s* e Zd ZdZdZddd�Zdddd�ZdS )r
z Simple API for ephemeral queues.TF)�durable� auto_delete� transient)rf �
delivery_moderg N)rO rP rQ rd r# rW rY r r r r r
� s �
�r
)rd �
__future__r r1 � collectionsr r% r �timer �typingr � r r r. r
�typesr �__all__r r r
r r r r �<module> s d#