def cancel_consumer(self, queue, destination=None, **kwargs):
    'Tell all (or specific) workers to stop consuming from ``queue``.\n\n        See Also:\n            Supports the same arguments as :meth:`broadcast`.\n        '
    return self.broadcast('cancel_consumer', destination=destination, arguments={'queue': queue}, **kwargs)
Tell all (or specific) workers to stop consuming from ``queue``.

See Also:
    Supports the same arguments as :meth:`broadcast`.
def cancel_consumer(self, queue, destination=None, **kwargs):
    'Tell all (or specific) workers to stop consuming from ``queue``.\n\n        See Also:\n            Supports the same arguments as :meth:`broadcast`.\n        '
    return self.broadcast('cancel_consumer', destination=destination, arguments={'queue': queue}, **kwargs)