ActiveMQ：将消息存储到python中的字符串

Question

我想将从ActiveMQ中的队列获取的消息存储到字符串中，但我找不到如何执行该操作。我的代码如下：

import stomp
import time

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

conn = stomp.Connection10()

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

conn.start()

conn.connect()

conn.subscribe('test2')



time.sleep(1) # secs

conn.disconnect()

Answer 1

在你的课堂上，你只需要打印你收到的信息，你需要：

• 将消息存储在列表中
• 实例化类“SampleListener”并返回列表

请参阅下面的代码添加。在

import stomp
import time

class SampleListener(object):

  #define your empty list used to store the messages
  def __init__(self):
    self.message_list = []

  def on_message(self, headers, msg):

    # appends new msg to message_list
    self.message_list.append((headers, msg))

    # comment this out if you dont want to print all msgs to console
    print(msg) 

conn = stomp.Connection10()

# instantiate the class
listener = SampleListener()

conn.set_listener('SampleListener', listener)

conn.start()

conn.connect()

conn.subscribe('test2')



time.sleep(1) # secs

conn.disconnect()

# messages received during the 1 second period stored in a list called "myMessages"
myMessages = listener.message_list