o wvXj@s4dZddlmZmZddlmZGdddeZdS)zEThe ``celery list bindings`` command, used to inspect queue bindings.)absolute_importunicode_literals)Commandc@s&eZdZdZdZddZdddZdS) list_zGet info from broker. Note: For RabbitMQ the management plugin is required. Example: .. code-block:: console $ celery list bindings z [bindings]cspz|}Wn tydwfdd}|ddd|ddd|D]}||d|d |d q'dS) Nz$Your transport cannot list bindings.csd|||S)Nz{0:<28} {1:<28} {2})outformat)qerselfL/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/bin/list.pyfmtsz list_.list_bindings..fmtQueueExchangez Routing Keyz---------------- destinationsource routing_key) get_bindingsNotImplementedErrorError)r managementbindingsrbr r r list_bindingss      zlist_.list_bindingsNcOsd|ji}d|}|s|d|||vr!|d|||j}|jj||||j WddS1sBwYdS)Nrz, z%Missing argument, specify one of: {0}z(unknown topic {0!r} (choose one of: {1})) rjoin UsageErrorrapp connectionamqp TaskConsumerdeclaremanager)r what_kwtopics availableconnr r rrun"s   "z list_.run)N)__name__ __module__ __qualname____doc__argsrr*r r r rrs   rN)r. __future__rrcelery.bin.baserrr r r rs