python - Stomp.py 如何从监听器返回消息

Question

我已经读过这个主题:Stomp.py return message from listener

但我仍然不明白它是如何工作的，以及为什么没有办法从 stomp 对象或直接从监听器检索消息？

如果我可以通过 send 方法发送消息，并且如果我可以使用 on_message 监听器方法接收消息，为什么我不能将该消息返回到我的原始函数，以便我可以将它返回到前端？

如果我有:

class MyListener(object):
    def on_error(self, headers, message):
        print '>>> ' + message
    def on_message(self, headers, message):
        print '>>> ' + message

如何从 on_message 方法返回消息？

或者我可以在 conn.subscribe(...) 之后以某种方式完成吗？？

Answer 1

好吧，我自己找到了一个方法。您所要做的就是稍微更改一下监听器类:

class MyListener(object):
    msg_list = []

    def __init__(self):
        self.msg_list = []

    def on_error(self, headers, message):
        self.msg_list.append('(ERROR) ' + message)

    def on_message(self, headers, message):
        self.msg_list.append(message)

在代码中，你使用 stomp.py 的地方:

conn = stomp.Connection()
lst = MyListener()
conn.set_listener('', lst)
conn.start()
conn.connect()
conn.subscribe(destination='/queue/test', id=1, ack='auto')
time.sleep(2)
messages = lst.msg_list
conn.disconnect()
return render(request, 'template.html', {'messages': messages})