ActiveMQ Artemis продлевает тайм-аут ClientConsumer.close()JAVA

Программисты JAVA общаются здесь
Anonymous
ActiveMQ Artemis продлевает тайм-аут ClientConsumer.close()

Сообщение Anonymous »

Я использую сервер, реализованный на Java, на котором во время работы открыто несколько потребителей для ActiveMQ Artemis.
В настоящее время у меня настроены потребители на отправку подтверждений после обработки логики. эти события завершаются, и когда серверу необходимо завершить работу, я хотел бы корректно закрыть все эти объекты org.apache.activemq.artemis.api.core.client.ClientConsumer. Однако, поскольку обработка моих событий иногда может занять 30-40 секунд, я постоянно сталкиваюсь с этим предупреждающим сообщением при вызове ClientConsumer.close():

Код: Выделить всё

W: [SLF4J org.apache.activemq.artemis.core.client] AMQ212002: Timed out waiting for handler to complete processing
Я вижу, что этот журнал взят из закрывающего кода и что в нем жестко запрограммировано ожидание завершения обработки событий в течение 10 секунд, поэтому мне интересно, есть ли какой-нибудь другой способ выполнить это безопасное закрытие клиентов-потребителей и возможность ожидания завершения событий более 10 секунд.

Подробнее здесь: https://stackoverflow.com/questions/790 ... se-timeout

Вернуться в «JAVA»