
    h.                     4    d Z ddlmZ ddlmZ  G d d      Zy)z,Implementation for the app.events shortcuts.    )contextmanager)cached_propertyc                   j    e Zd ZdZdZdZdZddZed        Z	ed        Z
ed	        Ze	 	 dd
       Zy)EventszImplements app.events.z$celery.events.receiver:EventReceiverz(celery.events.dispatcher:EventDispatcherzcelery.events.state:StateNc                     || _         y N)app)selfr	   s     M/var/www/Befach/backend/env/lib/python3.12/site-packages/celery/app/events.py__init__zEvents.__init__   s	        c                 P    | j                   j                  | j                  d      S )Nzevents.Receiverreverse)r	   subclass_with_selfreceiver_clsr
   s    r   ReceiverzEvents.Receiver   s*    xx**'8 + : 	:r   c                 P    | j                   j                  | j                  d      S )Nzevents.Dispatcherr   )r	   r   dispatcher_clsr   s    r   
DispatcherzEvents.Dispatcher   s*    xx**)< + > 	>r   c                 P    | j                   j                  | j                  d      S )Nzevents.Stater   )r	   r   	state_clsr   s    r   StatezEvents.State   s'    xx**NNN + 4 	4r   c              #     K   | j                   j                  j                  j                  d      5 }| j	                  |j
                  |||j                  |      5 }| d d d        d d d        y # 1 sw Y   xY w# 1 sw Y   y xY ww)NT)block)r	   amqpproducer_poolacquirer   
connectionchannel)r
   hostnameenabledbuffer_while_offlineprodds         r   default_dispatcherzEvents.default_dispatcher    s      XX]]((00t0< 	 (G!%/CE HI	 	 	 	s4   1B*A?A3"A?*	B3A<	8A??BBr   )NTF)__name__
__module____qualname____doc__r   r   r   r   r   r   r   r   r   r'    r   r   r   r      so     9L?N+I : : > > 4 4 8<05 r   r   N)r+   
contextlibr   kombu.utils.objectsr   r   r,   r   r   <module>r/      s    2 % /! !r   