rabbit.py 文件源码

def publish_message_to_queue(self, queue):
        uid = utils.generate_uuid()
        producer = kombu.Producer(channel=self.ch, routing_key=queue)
        producer.publish(uid)
        return {'queue': queue, 'id': uid}