Как читать сообщения из очередей Activemq с помощью Python и STOMP ⇐ Python

[Anonymous]

Я получаю доступ к очередям (activemq) по ссылке http://10.41.248.10:8161/admin/queues.jsp. Я хотел прочитать сообщение из очереди с именем: Notificationqueue. Я хотел использовать Python и STOMP. Имя пользователя и пароль для очереди — admin/admin. Пожалуйста, помогите мне шаг за шагом получить сообщение из очереди с именем: Notificationqueue. Ниже приведен мой код, помогите, пожалуйста, завершить код

Код: Выделить всё

#!/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()

Когда я запускаю это, я получаю сообщение об ошибке:

Код: Выделить всё

 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

. Пожалуйста, помогите заполнить этот код как можно скорее. Спросите меня, нужна ли вам дополнительная информация

Подробнее здесь: https://stackoverflow.com/questions/521 ... -and-stomp