I Access queues (ActiveMQ) с использованием ссылки http://10.41.248.10:8161/admin/queues.jsp. Я хотел прочитать сообщение с имени очереди: natificationQueue. Я хотел использовать Python и Stomp. Имя пользователя и пароль в очередь - Admin/Admin. Пожалуйста, помогите мне шаг за шагом, чтобы получить сообщение от Имя очереди: natificationQueue. Ниже приведен мой код, пожалуйста, помогите завершить код < /p>
#!/usr/bin/env python
import time
import sys
import stomp
class MyListener(object):
def on_error(self, headers, message):
print 'received an error %s' % message
def on_message(self, headers, message):
print 'received a message %s' % message
conn = stomp.Connection(host_and_ports=[('10.41.248.10', 61616)])
conn.set_listener('', MyListener())
conn.start()
conn.connect("admin","admin",wait=True)
conn.subscribe(destination='queue://Notificationqueue', id = '1', ack='auto')
time.sleep(2)
conn.disconnect()
< /code>
Когда я запускаю это, я получаю ошибку, < /p>
No handlers could be found for logger "stomp.py"
conn.connect("admin","admin", wait=True)
File "C:\Python27\lib\site-packages\stomp\connect.py", line 164, in connect
Protocol11.connect(self, *args, **kwargs)
File "C:\Python27\lib\site-packages\stomp\protocol.py", line 340, in connect
self.transport.wait_for_connection()
File "C:\Python27\lib\site-packages\stomp\transport.py", line 327, in wait_for_connection
raise exception.ConnectFailedException()
ConnectFailedException
< /code>
. Пожалуйста, помогите в завершении этого кода в ближайшее время. Спросите меня, нужно ли вам больше информации
Подробнее здесь: https://stackoverflow.com/questions/521 ... -and-stomp
