Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/__pycache__/memory.cpython-39.pyc
Ðазад
a o�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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка