问题描述
我正在使用pika Python客户端进行RabbitMQ消息交换框架。
在一个Python程序上： 我正在发送消息请求以删除客户端 我是在Node-RED的背景下完成的
远程客户端响应后，将调用注册的回叫。 此响应将有一个对象，我需要将其传递回NODE RED
我该如何实现？ 请注意流程：
程序＃1 节点RED-> Python Program1 ==>发送RabbitMQ消息->注册回调函数
程序＃2 远程客户端发送响应->已执行已注册的回叫->，但是它无权访问NODE RED消息队列详细信息。因此，无法将响应对象直接从此处发回给node-red
我需要做的是将一个响应对象共享回Program＃1中。 我可以等一些事件-
PS：进程1不是由进程1创建的-因为回调是独立调用的
这是我的代码-
"""
Following statement declares an exchange that is direct type.
Each message sent to direct exchange will be copied only to the
queue bound to that exchange
"""
channel.exchange_declare(exchange='test-direct',exchange_type='direct')
"""
Create a queue dynamically and wait on the queue
"""
channel.queue_declare(queue="test1")
"""
Bind this queue to a direct exchange,so that the reply messages sent
to this queue are consumed only by server - not fanned out
"""
channel.queue_bind(exchange='test-direct',queue="test1")
channel.basic_publish(exchange="test-direct",routing_key=ipaddress,properties=pika.BasicProperties(
reply_to="test1"),body=str(msg_tobe_sentto_remote_hosts))
channel.basic_consume(
queue="test1",on_message_callback= ProcessReceivedMessage,auto_ack=True)
logger.info(' [*] Waiting for messages. To exit press CTRL+C')
try:
channel.start_consuming()
except KeyboardInterrupt:
logger.critical("Keyboard Interrupt Received --exiting")
channel.close()
exit
return msg
"""
Function name: ProcessReceivedMessage
"""
def ProcessReceivedMessage (ch,method,properties,body):
body = body.decode('utf-8')
logger.info("Inside ProcessReceivedMessage ")
logger.info (body)
return(body)
现在我的问题是，上面声明队列的第一个函数将其绑定等等，-我希望该函数能够接收已成为第二个函数“ ProcessReceivedMEssage”的消息的消息。 我该怎么办？
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）