提问者:小点点

PythonSTOMP不接收来自ActiveMQ的消息


import time
import sys
import stomp

class ConnectionListener(object):
    def on_error(self, message):
        print('received an error %s' % message)
    def on_message(self, message):
        print('received a message %s' % message)
        print(message.body)
        with open('/usr/ubuntu/result.txt', 'w') as txt_file:
            txt_file.write(str(message))
conn = stomp.Connection(host_and_ports=[('localhost', 61613)])
conn.set_listener('', ConnectionListener())


conn.connect("admin", "admin", wait=True)

conn.subscribe(destination='/topic/topictest', id='1', ack='auto')

time.sleep(2)
conn.disconnect()

也许问题出在我给出的目的地上。所以我尝试更改目标='/topic/…'。什么都没发生。我需要我的代码来显示消息。


共1个答案

匿名用户

你似乎错过了:

conn. start()

conn. connect()方法之前的行。