U d"@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. Nctxrr3/tmp/pip-unpacked-wheel-mu1yl971/celery/bin/list.pylist_sr )clsc sjj}|}|j|z|j}Wntk rNt dYnXfdd}|ddd|ddd|D]}||d|d |d qxW5QRXd 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