我已经配置了两个订阅主题的消费者。现在,当我收到有关该主题的消息时,两个消费者都在使用相同的消息。在我从某个进程中得到确认之前,我不会删除该消息,这样我就不会丢失任何消息。
我打算做的是,当我有 2 条消息时,每个消费者应该分别为前第一个消费者处理第一条消息和第二个消费者处理第二条消息的消息。
我已经用java编写了我所有的代码(生产者,消费者)(没有使用像spring maven等这样的框架。)
我怎样才能做到这一点?
Topic
发布消息以供多个消费者使用,而Queue
发布消息仅供一个消费者使用。所以我相信你需要使用Queue
而不是Topic
.
阅读有关主题和队列差异的更多信息:
http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html