def _queue(self, conn=None): exchange = kombu.Exchange(self.channel, type='fanout', durable=False) queue = kombu.Queue(str(uuid.uuid4()), exchange) return queue