@control_command(args=[(u'queue', text_t), (u'exchange', text_t), (u'exchange_type', text_t), (u'routing_key', text_t)], signature=u'<queue> [exchange [type [routing_key]]]')
def add_consumer(state, queue, exchange=None, exchange_type=None, routing_key=None, **options):
 state.consumer.call_soon(state.consumer.add_task_queue, queue, exchange, (exchange_type or u'direct'), routing_key, **options)
 return ok(u'add consumer {0}'.format(queue))

@ control_command ( args = [ ( u'queue' , text_t ) , ( u'exchange' , text_t ) , ( u'exchange_type' , text_t ) , ( u'routing_key' , text_t ) ] , signature = u'<queue> [exchange [type [routing_key]]]' ) def add_consumer ( state , queue , exchange = None , exchange_type = None , routing_key = None , ** options ) : state . consumer . call_soon ( state . consumer . add_task_queue , queue , exchange , ( exchange_type or u'direct' ) , routing_key , ** options ) return ok ( u'add consumer {0}' . format ( queue ) )
tell worker(s) to consume from task queue by name .