我试图从一个巨大的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())
当前脚本没有其他错误
目前没有回答
相关问题 更多 >
编程相关推荐