Как увеличить время автоблокировки на служебной шине Azure с использованием верблюда - PullRequest
0 голосов
/ 08 ноября 2018

Я использую сервисную шину 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);

Я что-то здесь упускаю? ТИА.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...