如何从Stomp侦听器类中获取消息数据?

2024-04-25 05:34:23 发布

您现在位置:Python中文网/ 问答频道 /正文

我试图从一个巨大的activemq队列中检索消息。我可以很好地连接,并且已经成功地向它发送了消息

我现在遇到的一个问题是如何实际检索要处理的消息。我发现我需要声明一个全局变量列表来放入消息,并且消息列表在类中的大小会增加(print(len(msglist)),但我还无法从类中实际获取该消息列表,以便脚本的其余部分可以处理消息(它们是对另一个系统的排队api请求)

由于一个对SampleListener类的引用似乎是一个循环(msglist每次运行时都会增加几千个),我不确定如何使用return语句(每次循环完成时都会返回?)

import stomp
msglist=[]

class SampleListener(object):
    def on_message(self, headers, msg):
        global msglist

        msglist.append(msg)

conn = stomp.Connection10()

conn.set_listener('SampleListener', SampleListener())

当前脚本没有其他错误


Tags: 脚本声明消息列表len队列msgconn