a xd"@sXdZddlZddlmZmZejddejeddZejedejd d Z dS) zEThe ``celery list bindings`` command, used to inspect queue bindings.N) CeleryCommandhandle_preload_optionslist)namecCsdS)z^Get info from broker. Note: For RabbitMQ the management plugin is required. NctxrrG/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/bin/list.pylist_sr )clsc sjj}|}|j|z|j}WntyLt dYn0fdd}|ddd|ddd|D]}||d|d |d qvWd n1s0Yd S) zInspect queue bindings.z$Your transport cannot list bindings.cs$j|dd|dd|dS)Nz<28 )objZecho)qerrrr fmt!szbindings..fmtQueueZExchangez Routing Keyz----------------Z destinationsourceZ routing_keyN) r app connectionZamqpZ TaskConsumerZdeclaremanagerZ get_bindingsNotImplementedErrorclickZ UsageError)rrconnbindingsrbrrr rs     r) __doc__rZcelery.bin.baserrgroupZ pass_contextr commandrrrrr s