'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):

    return self.broadcast(u'cancel_consumer', destination=destination, arguments={u'queue': queue}, **kwargs)
