Я использую сервисную шину Azure для своего проекта. Мне удалось установить соединение через Camel amqp по этой ссылке Доступ к служебной шине Azure с помощью Apache Camel?
Теперь я могу читать сообщения через очередь служебной шины, но у меня возникают проблемы с увеличением блокировки тайм-аута для сообщений. Я установил блокировку тайм-аута равной 30 секундам в свойствах служебной шины, но для определенных сообщений, которым требуется больше времени, я хочу, чтобы время увеличилось.
Я искал решение в Интернете, но не смог найти ничего, что решило бы проблему. Я пытался использовать backoffmultiplier (), доступный с верблюдом, но он тоже не удался.
Ниже моя реализация того, что я пробовал до сих пор.
URI для подключения к очереди, в которой я указал requestTimeout и requestTimeoutChecker
QUEUE_CONNECTION=amqp:queue:testqueue?requestTimeout=4000&requestTimeoutCheckerInterval=3000&acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=2
Обработка исключений, когда я использовал backoffmultiplier
onException(Exception.class).
process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
logger.error("Exception in exchange : ",cause);
// we now have the caused exception
}
}).useExponentialBackOff().backOffMultiplier(2).maximumRedeliveries(3);
Я что-то здесь упускаю? ТИА.