def add_consumer(self, queue, exchange=None, exchange_type='direct', routing_key=None, options=None, destination=None, **kwargs):
    "Tell all (or specific) workers to start consuming from a new queue.\n\n        Only the queue name is required as if only the queue is specified\n        then the exchange/routing key will be set to the same name (\n        like automatic queues do).\n\n        Note:\n            This command does not respect the default queue/exchange\n            options in the configuration.\n\n        Arguments:\n            queue (str): Name of queue to start consuming from.\n            exchange (str): Optional name of exchange.\n            exchange_type (str): Type of exchange (defaults to 'direct')\n                command to, when empty broadcast to all workers.\n            routing_key (str): Optional routing key.\n            options (Dict): Additional options as supported\n                by :meth:`kombu.entitiy.Queue.from_dict`.\n\n        See Also:\n            :meth:`broadcast` for supported keyword arguments.\n        "
    return self.broadcast('add_consumer', destination=destination, arguments=dict({'queue': queue, 'exchange': exchange, 'exchange_type': exchange_type, 'routing_key': routing_key}, **(options or {})), **kwargs)
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='direct', routing_key=None, options=None, destination=None, **kwargs):
    "Tell all (or specific) workers to start consuming from a new queue.\n\n        Only the queue name is required as if only the queue is specified\n        then the exchange/routing key will be set to the same name (\n        like automatic queues do).\n\n        Note:\n            This command does not respect the default queue/exchange\n            options in the configuration.\n\n        Arguments:\n            queue (str): Name of queue to start consuming from.\n            exchange (str): Optional name of exchange.\n            exchange_type (str): Type of exchange (defaults to 'direct')\n                command to, when empty broadcast to all workers.\n            routing_key (str): Optional routing key.\n            options (Dict): Additional options as supported\n                by :meth:`kombu.entitiy.Queue.from_dict`.\n\n        See Also:\n            :meth:`broadcast` for supported keyword arguments.\n        "
    return self.broadcast('add_consumer', destination=destination, arguments=dict({'queue': queue, 'exchange': exchange, 'exchange_type': exchange_type, 'routing_key': routing_key}, **(options or {})), **kwargs)