File: //usr/local/lib/python3.9/site-packages/kombu/transport/__pycache__/memory.cpython-39.pyc
a
X>hd � @ s` d Z ddlmZ ddlmZ ddlmZ ddlmZm Z G dd� de j
�Z
G d d
� d
e j �Z d S ) a� In-memory transport module for Kombu.
Simple transport using memory for storing messages.
Messages can be passed only between threads.
Features
========
* Type: Virtual
* Supports Direct: Yes
* Supports Topic: Yes
* Supports Fanout: No
* Supports Priority: No
* Supports TTL: Yes
Connection String
=================
Connection string is in the following format:
.. code-block::
memory://
� )� annotations)� defaultdict)�Queue� )�base�virtualc s� e Zd ZdZee�Zi ZdZdZ dd� Z
dd� Z d d d
�Z d d � Z
d
d� Zd dd�Zdd� Zdd� Zdd� Zdd� Z� fdd�Zdd � Z� ZS ) �ChannelzIn-memory Channel.FTc K s
|| j v S �N)�queues��self�queue�kwargs� r �@/usr/local/lib/python3.9/site-packages/kombu/transport/memory.py�
_has_queue) s zChannel._has_queuec K s || j vrt� | j |< d S r �r
r r r r r �
_new_queue, s
zChannel._new_queueNc C s | � |�jdd�S )NF)�block)�
_queue_for�get)r r
�timeoutr r r �_get0 s z Channel._getc C s || j vrt� | j |< | j | S r r �r r
r r r r 3 s
zChannel._queue_forc G s d S r r )r �argsr r r � _queue_bind8 s zChannel._queue_bindc K s& | � ||�D ]}| �|��|� q d S r )Z_lookupr �put)r Zexchange�messageZ routing_keyr r
r r r � _put_fanout; s zChannel._put_fanoutc K s | � |��|� d S r )r r )r r
r r r r r �_put? s z Channel._putc C s | � |��� S r )r �qsizer r r r �_sizeB s z
Channel._sizec O s | j �|d � d S r )r
�pop)r r
r r r r r �_deleteE s zChannel._deletec C s | � |�}|�� }|j�� |S r )r r r
�clear)r r
�q�sizer r r �_purgeH s
zChannel._purgec s, t � �� | j�� D ] }|�� qi | _d S r )�super�closer
�values�emptyr �� __class__r r r) N s
z
Channel.closec C s d S r r r r r r � after_reply_message_receivedT s z$Channel.after_reply_message_received)N)N)�__name__�
__module__� __qualname__�__doc__r �set�eventsr
Z
do_restoreZsupports_fanoutr r r r r r r r! r# r' r) r. �
__classcell__r r r, r r ! s"
r c sD e Zd ZdZeZe�� Zej j
Z
dZ dZ � fdd�Z
dd� Z� ZS )� TransportzIn-memory Transport.Zmemoryc s t � j|fi |�� | j| _d S r )r( �__init__� global_state�state)r �clientr r, r r r7 e s zTransport.__init__c C s dS )NzN/Ar )r r r r �driver_versioni s zTransport.driver_version)r/ r0 r1 r2 r r Z BrokerStater8 r r6 Z
implementsZ driver_typeZ driver_namer7 r; r5 r r r, r r6 X s r6 N) r2 �
__future__r � collectionsr r
r � r r r r6 r r r r �<module> s 7