如何从 Python 中的 ActiveMQ 读取队列？

Question

我尝试return队列中的数据

import stomp
conn = stomp.Connection([('Host','port')])
conn.connect(wait = True)-
print(conn.subscribe('test_queue', headers={}))

但是我得到了错误

----> 3 print(conn.subscribe('test_queue', headers={}))
TypeError: subscribe() missing 1 required positional argument: 'id'

Answer 1

错误提示缺少 id 参数。

在 document 中，您可以找到信息。

id (str) – the identifier to uniquely identify the subscription

您可以设置例如123作为一个唯一的id，并在退订时使用该id。

from stomp import *
c = Connection([('127.0.0.1', 62613)])
....
c.subscribe('/queue/test', 123)
c.unsubscribe(123)

How to read a queue from ActiveMQ in Python?