如何在rabbitmq中浏览队列而不使消息出队

Question

我正在尝试获取具有特定相关 ID 的消息，如rabbitmq 文档中所述。但是我看到不相关的消息被出队。我不希望它发生。在我收到消息并知道这不是我要找的消息后，如何告诉rabbitmq不要出队。请帮我。

`

.
.
replyQueueName = channel.queueDeclare().getQueue();
consumer = new QueueingConsumer(channel);
channel.basicConsume(replyQueueName, false, consumer);
while (true) {
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            System.out.println(delivery.getProperties().getCorrelationId());
            if (delivery.getProperties().getCorrelationId().equals(corrId)) {
                response = new String(delivery.getBody());
                break;
            }
        }

`

Answer 1

如果您可以承受丢失消息顺序的损失，则可以使用重新排队机制。

尝试关闭自动确认。

如果没有，您必须重新设计应用程序以注入标头或路由键以路由到特定队列。