@control_command(args=[(u'queue', text_t)], signature=u'<queue>')
def cancel_consumer(state, queue, **_):
 state.consumer.call_soon(state.consumer.cancel_task_queue, queue)
 return ok(u'no longer consuming from {0}'.format(queue))

@ control_command ( args = [ ( u'queue' , text_t ) ] , signature = u'<queue>' ) def cancel_consumer ( state , queue , ** _ ) : state . consumer . call_soon ( state . consumer . cancel_task_queue , queue ) return ok ( u'no longer consuming from {0}' . format ( queue ) )
tell worker(s) to stop consuming from task queue by name .