AMQP потребитель (слушатель адаптера + SimpleMessageListenerContainer), содержащее сообщение

Question

Недавно мы столкнулись с ситуацией, когда сообщения были доставлены из очереди потребителем, но не доходили до слушателя, связанного с этой очередью. Мы смогли сделать это утверждение, потому что у нас есть перехватчик для наших слушателей (который печатает сообщение журнала), который не был вызван для этих сообщений. Как только мы перезапустили сервер (tomcat), сообщения были израсходованы и удалены.

Мы хотели бы знать причину такого поведения. Мы проанализировали дампы потоков, но безуспешно.

Answer 1

Такие вопросы всегда вызваны одной из двух задач:

• контейнер нить (ы) «застрял» в пользовательском коде
• некоторых сетевых компонентов (например, маршрутизатор) молча закрывающая соединение, которое он считает простаивает, так что клиент и/или сервер не знают, что соединение закрыто.

Вы, кажется, устранили первый (при условии, что ваш анализ правильный), поэтому он, скорее всего, второй.

Вы можете включить биение сердца при подключении, чтобы сеть не считала, что соединение простаивает. Обратитесь к документации RabbitMQ.