擅长:python、mysql、java
<p>您所要做的就是对listener类进行一点小小的更改:</p>
<pre><code>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)
</code></pre>
<p>在代码中,使用stomp.py:</p>
<pre><code>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})
</code></pre>
<p><a href="https://stackoverflow.com/questions/23077284/stomp-py-how-to-return-message-from-listener">Stomp.py how to return message from listener</a>-指向stackoverflow类似问题的链接</p>