在处理完整个包之前，不要让stomp.py从ActiveMQ中删除数据包

Question

我正在尝试使用stomp.py从activemq获取消息，然后对其进行一些处理。但是，有一种情况是，某些消息处理失败，而该消息丢失。

在邮件完全处理之前，如何防止删除消息？

例如，在我的代码中，当队列中有新条目时，将调用on_message函数并启动处理，但如果在消息之间中断，则会丢失。我该怎么阻止它？

这是我的代码：

conn = stomp.Connection([(host, 61613)])
conn.set_listener('ML', MyListener())
conn.start()
conn.connect('admin', 'admin', wait=True)
conn.subscribe(destination=/queue/someque, id=1, ack='auto')
print "running"
while 1:
    print 'waiting'
    time.sleep(2.5)

下面是我的侦听器类：

class MyListener(stomp.ConnectionListener):
    def on_message(self, headers, message):
        print headers
        print message
        do_something()

提前谢谢。

Answer 1

问题似乎是，您正在使用“auto”ack模式，因此消息在由代理传递给客户之前将被确认，这意味着即使您无法处理它，它也会延迟，因为它已经在代理端被遗忘了。您需要使用踩踏规格中描述的'client‘ack或’client-个性化‘ack模式。当代理实际确认和删除一条或多条消息时，使用您控制的客户端ack模式之一。