Служебная шина Azure — ServiceBusProcessorClient-Java — Trytimeout и обработка одновременных сеансов

Я использую ServiceBusProcessorClient и AmqpRetryOptions для подключения моей служебной шины Azure. Столкновение с двумя проблемами.

1. Потребитель ждет 30 секунд, чтобы обработать следующее сообщение от ASB. Это из-за настроек trytimeout? Я установил значение 30 секунд, поскольку, получив сообщение от ASB, мы вызываем API, и иногда для ответа может потребоваться 30 секунд.

2. Когда у меня есть одновременные сеансы и максимальное количество одновременных вызовов равно 4, от ASB потребуется 4 сообщения, но если одно из них выйдет из строя, в блоке исключений я выполняю функцию serviceBusProcessorClient.close(), которая остановит потребителя, и в этом случае он вернет в ASB все 4 сообщения, а не только ошибочное. Есть ли решение?

Конфигурация кода ниже, значения просто помещены в виде строки для простоты.

ampqRetryOptions.setDelay(Duration.ofSeconds(Integer.parseInt(serviceBusConfig.getAmpqDelay())));
        ampqRetryOptions.setMaxRetries(<5>);
        ampqRetryOptions.setMaxDelay(<1>);
        ampqRetryOptions.setMode(AmqpRetryMode.EXPONENTIAL);
        ampqRetryOptions.setTryTimeout(<30 seconds>);
serviceBusProcessorClient = new ServiceBusClientBuilder()
                .connectionString(connectioString).retryOptions(ampqRetryOptions)
                .sessionProcessor().maxConcurrentSessions(4))
                .maxConcurrentCalls(4))
                .queueName(<queueName>)
                .maxAutoLockRenewDuration(50 seconds)
                .processMessage(onMessage()).disableAutoComplete()
                .processError(onError)
                .buildProcessorClient();