
    h.                     4    S r SSKJr  SSKJr   " S S5      rg)z,Implementation for the app.events shortcuts.    )contextmanager)cached_propertyc                   v    \ rS rSrSrSrSrSrSS jr\	S 5       r
\	S	 5       r\	S
 5       r\  SS j5       rSrg)Events   zImplements app.events.z$celery.events.receiver:EventReceiverz(celery.events.dispatcher:EventDispatcherzcelery.events.state:StateNc                     Xl         g Napp)selfr   s     9D:\TimeStamps\venv\Lib\site-packages\celery/app/events.py__init__Events.__init__   s        c                 J    U R                   R                  U R                  SS9$ )Nzevents.Receiverreverse)r   subclass_with_selfreceiver_clsr   s    r   ReceiverEvents.Receiver   s*    xx**'8 + : 	:r   c                 J    U R                   R                  U R                  SS9$ )Nzevents.Dispatcherr   )r   r   dispatcher_clsr   s    r   
DispatcherEvents.Dispatcher   s*    xx**)< + > 	>r   c                 J    U R                   R                  U R                  SS9$ )Nzevents.Stater   )r   r   	state_clsr   s    r   StateEvents.State   s'    xx**NNN + 4 	4r   c              #   &  #    U R                   R                  R                  R                  SS9 nU R	                  UR
                  XUR                  U5       nUv   S S S 5        S S S 5        g ! , (       d  f       N= f! , (       d  f       g = f7f)NT)block)r   amqpproducer_poolacquirer   
connectionchannel)r   hostnameenabledbuffer_while_offlineprodds         r   default_dispatcherEvents.default_dispatcher    st      XX]]((00t0< (!%/CEHIE =<E E =<s4   .B)B A/B &	B/
A=	9B  
B
Br
   r	   )NTF)__name__
__module____qualname____firstlineno____doc__r   r   r   r   r   r   r   r   r   r-   __static_attributes__ r   r   r   r      so     9L?N+I : : > > 4 4 8<05 r   r   N)r3   
contextlibr   kombu.utils.objectsr   r   r5   r   r   <module>r8      s    2 % /! !r   