【发布时间】:2015-09-07 23:04:09
【问题描述】:
所以我已经声明了一个长度为 1 的队列,并且发布者不会自动确认消息,这意味着我已经确认了我收到的每条消息。那么这里没有确认的消息会发生什么?
当新消息到达队列时,旧的未确认消息会发生什么变化?
Map < String, Object > args = new HashMap < String, Object > ();
args.put("x-max-length", 1);
channel.queueDeclare("myqueue", false, false, false, args);
channel.basicConsume("myqueue", false, consumer);
我想要实现的是 myqueue 应该只保存一条消息,并且任何发布者都可以阅读该消息,但它不应该删除该消息。当新消息到达队列时,它应该删除该消息并放入新消息。
【问题讨论】:
标签: java rabbitmq message-queue