File: //proc/self/root/usr/local/lib/python3.9/site-packages/celery/app/__pycache__/events.cpython-39.pyc
a
X>h. � @ s. d Z ddlmZ ddlmZ G dd� d�ZdS )z,Implementation for the app.events shortcuts.� )�contextmanager)�cached_propertyc @ sX e Zd ZdZdZdZdZddd�Zedd � �Z ed
d � �Z
ed d
� �Z e ddd��Z
dS )�EventszImplements app.events.z$celery.events.receiver:EventReceiverz(celery.events.dispatcher:EventDispatcherzcelery.events.state:StateNc C s
|| _ d S )N)�app)�selfr � r �;/usr/local/lib/python3.9/site-packages/celery/app/events.py�__init__ s zEvents.__init__c C s | j j| jdd�S )Nzevents.Receiver��reverse)r �subclass_with_self� receiver_cls�r r r r �Receiver s �zEvents.Receiverc C s | j j| jdd�S )Nzevents.Dispatcherr
)r r �dispatcher_clsr r r r �
Dispatcher s �zEvents.Dispatcherc C s | j j| jdd�S )Nz events.Stater
)r r � state_clsr r r r �State s �z Events.StateTFc c sr | j jjjdd��L}| �|j|||j|��}|V W d � n1 sF0 Y W d � n1 sd0 Y d S )NT)�block)r ZamqpZ
producer_pool�acquirer �
connectionZchannel)r �hostname�enabledZbuffer_while_offline�prod�dr r r �default_dispatcher s �zEvents.default_dispatcher)N)NTF)�__name__�
__module__� __qualname__�__doc__r
r r r r r r r r r r r r r r s
�r N)r �
contextlibr Zkombu.utils.objectsr r r r r r �<module> s