o
    h                     @   sP   d Z ddlmZ ddlmZ ddlmZ dZeeZ	e	j
Z
G dd dejZdS )	z$Consumer Broker Connection Bootstep.    )ignore_errors)	bootsteps)
get_logger)
Connectionc                       s8   e Zd ZdZ fddZdd Zdd Zdd	 Z  ZS )
r   z0Service managing the consumer broker connection.c                    s   d |_ t j|fi | d S N)
connectionsuper__init__)selfckwargs	__class__ c/var/www/html/optinet_system/venv/lib/python3.10/site-packages/celery/worker/consumer/connection.pyr	      s   zConnection.__init__c                 C   s   |  |_td|j  d S )NzConnected to %s)connectr   infoas_uri)r
   r   r   r   r   start   s   
zConnection.startc                 C   s&   |j d }|_ |rt||j d S d S r   )r   r   close)r
   r   r   r   r   r   shutdown   s   zConnection.shutdownc                 C   s(   d}|j r|j  }|dd  d|iS )NzN/Apasswordbroker)r   r   pop)r
   r   paramsr   r   r   r      s
   
zConnection.info)	__name__
__module____qualname____doc__r	   r   r   r   __classcell__r   r   r   r   r      s    r   N)r   kombu.commonr   celeryr   celery.utils.logr   __all__r   loggerr   StartStopStepr   r   r   r   r   <module>   s    