Я работаю над приложением, которое берет сообщения из очереди и доставляет их в другой экземпляр.Всякий раз, когда этот экземпляр, сообщения должны быть помещены обратно в очередь с задержкой доставки.
Я работаю с ActiveMQ и использую AMQP & Camel.Чтобы сделать это без повторной доставки, я использую класс JmsConnectionFactory.class.Если бы я хотел, чтобы повторная доставка работала, я бы использовал ActiveMQConnectionFactory.class, единственная проблема в том, что вы должны работать там с TCP, а мне сказали не делать этого.
Все, что я хочу настроить, этовозможно использование RedeliveryPolicy из ActiveMQConnectionFactory, но поскольку клиент отправляет сообщения с помощью AMQP, данные неправильно обрабатываются и не читаются для моего приложения.
Класс JmsConnectionFactory также имеет политику повторной доставки, но проблема заключается в том, что выЯ могу установить только максимальное количество доставок, в то время как я хочу, чтобы мои сообщения имели некоторую задержку.
(я знаю, что повторная доставка верблюда возможна, и я также реализовал это, но план резервного копирования должен состоять в том, чтобы отправлять сообщения обратно наочередь)
Кто-нибудь знаком с этой проблемой и есть ли обходной путь?