Как произвести возврат c. Возврат с помощью QPid - PullRequest
0 голосов
/ 10 апреля 2020

Я использую rabbitmq в производстве и QPid в интеграционных тестах. Мне нужно написать интеграционный тест, который проверяет, что обратный канал вызывается для сообщений, которые не могут быть отправлены. Я устанавливаю обязательный = true и отменяю привязку очереди и обмена, однако вместо обратного канала вызывается канал nack (выбрасывается исключение NackedAmqpMessageException). Обратный канал никогда не вызывается.

Я использую Spring AMQP с Spring Boot + Spring Integration. Как я могу создать регистр обратного канала в тестах?

Я использую версии:

Qpid 7.1.4
Amqp client 5.4.3
Spring Integration 5.1.9
Spring Boot 2.1.2

Спасибо.

1 Ответ

1 голос
/ 10 апреля 2020

Есть ли подтверждение того, что QPid поддерживает Publisher Confirms: https://www.rabbitmq.com/confirms.html#publisher -confirms ? Если честно, мы рекомендуем использовать RabbitMQ даже для тестов. Посмотрите наш недавний пример, как это сделать с помощью Testcontaniers: https://github.com/spring-projects/spring-integration-samples/tree/master/intermediate/testcontainers-rabbitmq

...