def consuming_from(self, queue):
        """Return :const:`True` if the consumer is currently
        consuming from queue'."""
        name = queue
        if isinstance(queue, Queue):
            name = queue.name
        return name in self._active_tags
dataset/ETHPy150Open celery/kombu/kombu/messaging.py/Consumer.consuming_from/original