EventBus Google отключение гуавы

Question

EventBus Google отключение гуавы

В настоящее время я использую подход guava EventBus в моем приложении. Слушатель пытается выполнить какую-то работу, и, если это не удается, событие должно быть снова в шине и повторно отправлено.
Мой вопрос: что, если мое приложение закрывается (выполняет выключение)? Будет ли отправлять оставшиеся события в автобусе?

Я ищу какой-то подход, например, реализованный в ActiveMQ выключить hoow

если брокер установит хук отключения, чтобы он мог правильно отключиться при уничтожении JVM

К сожалению, я не нашел что-то подобное в гуаве EventBus.

3

guava event-bus shutdown-hook

Источник

user457208 14 июл '14 в 15:50

1 ответ

Решение

Другие вопросы по тегам guava event-bus shutdown-hook

user2590922 09 июл '15 в 09:29 2015-07-09 09:29 · Accepted Answer · 2015-07-09 09:29

Стандартная гуава EventBus синхронно, не имеет внутреннего Thread или что-то типа того. Если поток, который вызывает post(Object event) Умирает, EventBus перестает доставлять события (потому что он использует поток вызывающего).

AsyncEventBus с другой стороны, занимает Executor (от java.util.concurrent пакет) во время строительства, который используется для отправки событий. В этом случае это зависит от того, какую реализацию исполнителя вы используете. Например, ThreadPoolExecutor понадобится shutdownNow() позвонить, чтобы прекратить доставку сообщений.