-2

我按照以下链接到消费者连接 http://pika.readthedocs.org/en/latest/examples/asynchronous_consumer_example.html

我观察到一种特殊的行为，每当我关闭工人并再次重新启动它时，它就会充斥着事件。不知道为什么。这些事件基本上是之前传递给它的事件。

我的理解是，这些事件仍保留在交换中，当我启动我的工作人员时，它会连接到交换并再次获取所有事件。顺便说一句，我正在使用扇出交换类型

4

1 回答 1

0

问题是，一旦我收到事件，我就没有发回确认。这导致交换没有清除它收到的作业，并导致它在重新连接时再次加载

于 2015-03-12T06:08:17.923 回答