使用 python STOMP 从 ActiveMQ 队列接收单个消息

Question

• 您好，我正在使用 stomp.py 模块发送和接收来自
  的消息 使用 python 的 ActiveMQ。
• 在接收消息时，侦听器将在其中读取多条消息 指定的睡眠时间。
• 但我只需要阅读一条消息。在java中是可能的。如何 我可以使用 STOMP 从 ActiveMQ 读取一条消息吗？

这是我正在测试的监听器脚本，

import stomp
import time

class SampleListener(object):
  def on_message(self, headers, msg):
    print(msg)

conn = stomp.Connection([('localhost',61613)]) 
conn.set_listener('SampleListener', SampleListener()) 
conn.start() 
conn.connect() 
conn.subscribe(destination='queue_name', id=1, ack='auto')
time.sleep(10) # secs 
conn.disconnect()

Answer 1

如果您只想使用 STOMP 一次读取一条消息，唯一的方法是使用 ack 模式，例如 client 或 client-individual ，以便客户端仅在发送显式消息时才发送新消息确认它拥有的那个。这还需要将预取值设置为一个，以便代理不会向客户端发送一批消息。

STOMP 确认模式在规范here 中定义。经纪人的 STOMP 支持文档是 here。客户端使用 ActiveMQ 文档中列出的 SUBSCRIBE 上的标头“activemq.prefetchSize”设置预取。