Сообщение опубликовано, но не достигло брокера - PullRequest
0 голосов
/ 05 апреля 2019

Мой шаблон кролика настроен на использование CachingConnectionFactory с подключением в режиме кэширования.В редких случаях при вызове

rabbitTemplate.convertAndSend 

он проходит без каких-либо проблем, но сообщение никогда не получало брокера rabbitmq.

Несколько секунд после этого другой поток регистрирует: произошла непредвиденная ошибка драйвера соединения и stacktrace: com.rabbitmq.client.MissedHeartbeatException: Отсутствует пульс с heartbeat = 60 секунд

Есть ли конфигурация, котораяЯ должен активировать, чтобы быть уверенным, что сообщение получено посредником, или, по крайней мере, я ожидаю, что исключение будет выдано в потоке отправки?

1 Ответ

0 голосов
/ 05 апреля 2019

Рекомендуется включить Издатель подтверждает и возвращает на CachingConnectionFactory и mandatory для RabbitTemplate: https://docs.spring.io/spring-amqp/docs/2.1.4.RELEASE/reference/#cf-pub-conf-ret

...