'Return :const:`True` if currently consuming from queue\'.'

def consuming_from(self, queue):

    name = queue
    if isinstance(queue, Queue):
        name = queue.name
    return (name in self._active_tags)
