Предположим, у меня есть единственный экземпляр rabbitTemplate, и я вызываю rabbitTemplate.send （Message）, чтобы опубликовать сообщение на сервер RabbitMQ.
Вот что я хочу сделать: 1. с точки зрения издателя, как убедиться, что сообщение получено RabbitMQ? 2. На стороне потребителя я использую тот же rabbitTemplate для получения сообщения в потоке, и я хочу вручную подтвердить сообщение в другом потоке.
Есть ли способ вручную подтвердить сообщение RabbitTemplate?
Спасибо за любую помощь.
RabbitMQ является асинхронным, поэтому нет возможности «ждать», пока сообщение будет защищено посредником; вы можете включить подтверждения издателя, чтобы получать подтверждение того, что сообщение было доставлено в очередь. Дополнительную информацию см. В документации.
Вы не можете вручную подтвердить сообщение при использовании одного из receive*() методов; вам придется перейти к собственному API с помощью метода execute(); в обратном вызове выполните channel.basicGet(queue, false), чтобы получить сообщение, а затем channel.basicAck(deliveryTag).
concurrent-consumers), который вам не нужен / использовать второй пул потоков; вам не нужно ручное подтверждение, позвольте потоку контейнера выполнить подтверждение, когда вы закончите. Нет, вы не можете повторно открыть канал - если он закрыт, сообщение будет снова помещено в очередь в это время.
- person Gary Russell; 05.07.2014
