通过使用者回调函数_ python RabbitMQpika将消息发布到另一个队列

问题描述

我想知道是否可以在Rabbit-MQ消费者回调函数中发布消息？

## publish function (publisher)
def publish_data(data):
    channel.queue_declare(queue="another_queue")
    channel.basic_publish(exchange='',routing_key="another_queue",body=json.dumps({
        "message_title": data,}))


## the callback function we need to publish message to another queue
def consumer_callback(ch,method,properties,body):
    publish_data(data="they said hi from another queue")

## consumer 
def start_consumer():
     channel.queue_declare(queue=queue)
     channel.basic_consume(queue=queue,on_message_callback=consumer_callback,auto_ack=True)
     channel.start_consuming()

start_consumer()

我写了上面的代码，但出现错误：

Stream connection lost: IndexError('pop from an empty deque')
    raise exceptions.ChannelWrongStateError('Channel is closed.')
pika.exceptions.ChannelWrongStateError: Channel is closed.

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）