Плагин сообщений Delyed для apache qpid

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


rabbitmq junit qpid
person vipulk10    schedule 27.06.2018    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Я предполагаю, что, поскольку ваш вопрос помечен как «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 клиент, вам будет легко. Получите доступ к функции через JMS 2.0 API MessageProducer#setDeliveryDelay() или JMSProducer#setDeliveryDelay().

person k-wall    schedule 27.06.2018