o
    ›¨Êh"  ã                   @   sX   d Z ddlZddlmZmZ ejdd�ejedd„ ƒƒƒZejed�ejd	d
„ ƒƒZ	dS )zEThe ``celery list bindings`` command, used to inspect queue bindings.é    N)ÚCeleryCommandÚhandle_preload_optionsÚlist)Únamec                 C   s   dS )z^Get info from broker.

    Note:

        For RabbitMQ the management plugin is required.
    N© ©Úctxr   r   úA/var/www/html/env/lib/python3.10/site-packages/celery/bin/list.pyÚlist_   s    r
   )Úclsc              	      s´   ˆ j j}| ¡ �H}|j |¡ ¡  z|j ¡ }W n ty$   t	 
d¡‚w ‡ fdd„}|dddƒ |dddƒ |D ]}||d |d	 |d
 ƒ q9W d  ƒ dS 1 sSw   Y  dS )zInspect queue bindings.z$Your transport cannot list bindings.c                    s$   ˆ j  | d›d|d›d|› �¡ d S )Nz<28ú )ÚobjÚecho)ÚqÚeÚrr   r   r	   Úfmt!   s   $zbindings.<locals>.fmtÚQueueÚExchangezRouting Keyz----------------ÚdestinationÚsourceÚrouting_keyN)r   ÚappÚ
connectionÚamqpÚTaskConsumerÚdeclareÚmanagerÚget_bindingsÚNotImplementedErrorÚclickÚ
UsageError)r   r   ÚconnÚbindingsr   Úbr   r   r	   r#      s   

ÿÿ"ôr#   )
Ú__doc__r    Úcelery.bin.baser   r   ÚgroupÚpass_contextr
   Úcommandr#   r   r   r   r	   Ú<module>   s    

	