Delyaed плагин сообщений для Apache qpid - PullRequest
0 голосов
/ 27 июня 2018

Я использую apache qpid в качестве брокера для написания юнитов. Мой вариант использования требует использования функциональности отложенных сообщений в тестах. и qpid поддерживает это, как rabbitmq. У меня есть любой доступный плагин, который я могу написать в файле qpid json.

1 Ответ

0 голосов
/ 27 июня 2018

Я предполагаю, что поскольку ваш вопрос помечен как 'junit', вы пишете свои модульные тесты на Java и, вероятно, встраиваете Apache Qpid Broker-J .

Задержка доставки поддерживается. Вам не нужен плагин. Это описано здесь:

https://qpid.apache.org/releases/qpid-broker-j-7.0.6/book/Java-Broker-Concepts-Queues.html#Java-Broker-Concepts-Queue-HoldingEntries

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

Если вы используете JMS 2.0-совместимый клиент , жизнь проста. Доступ к функции через API JMS 2.0 MessageProducer#setDeliveryDelay() или JMSProducer#setDeliveryDelay().

...