'Tell all (or specific) workers to start consuming from a new queue.
Only the queue name is required as if only the queue is specified
then the exchange/routing key will be set to the same name (
like automatic queues do).
Note:
This command does not respect the default queue/exchange
options in the configuration.
Arguments:
queue (str): Name of queue to start consuming from.
exchange (str): Optional name of exchange.
exchange_type (str): Type of exchange (defaults to \'direct\')
command to, when empty broadcast to all workers.
routing_key (str): Optional routing key.
options (Dict): Additional options as supported
by :meth:`kombu.entitiy.Queue.from_dict`.
See Also:
:meth:`broadcast` for supported keyword arguments.'

def add_consumer(self, queue, exchange=None, exchange_type=u'direct', routing_key=None, options=None, destination=None, **kwargs):

    return self.broadcast(u'add_consumer', destination=destination, arguments=dict({u'queue': queue, u'exchange': exchange, u'exchange_type': exchange_type, u'routing_key': routing_key}, **(options or {})), **kwargs)
