Spring AMQP RabbitMQ - Обработка ошибок для прямого ответа

Я пытаюсь обработать исключения, которые возникают из-за amq.rabbitmq.reply-to-очереди, в частности таких вещей, как: "org.springframework.amqp.AmqpRejectAndDontRequeueException: Ответ получен после тайм-аута". Как я могу что-то настроить, чтобы справиться с этими исключениями? Я попытался установить правильность setErrorHandler, но, похоже, ничего не делает. Если я получаю сообщение об ошибке в своей очереди ввода, обработчик работает, но не с очередью ответа RPC. Есть идеи?

Заранее спасибо, Брайан

1 ответ

Решение

Как обсуждалось в Spring AMQP RabbitMQ RPC - для обработки исключений ответов вам нужен явный контейнер ответов для обработки ответов с большей сложностью; Вы можете подключить обработчик ошибок в этот контейнер.

В настоящее время не поддерживается добавление обработчика ошибок во встроенный контейнер прямого ответа.

Попробуйте открыть новую функцию.

Это было бы довольно тривиальным улучшением.

Другие вопросы по тегам