def _new_queue(self, queue, **kwargs):
        if queue not in self.queues:
            self.queues[queue] = Queue()
dataset/ETHPy150Open celery/kombu/kombu/transport/memory.py/Channel._new_queue/original