Class AsyncEventBus

java.lang.Object
com.google.common.eventbus.EventBus
com.google.common.eventbus.AsyncEventBus

@Beta public class AsyncEventBus extends EventBus
An EventBus that takes the Executor of your choice and uses it to dispatch events, allowing dispatch to occur asynchronously.
Since:
10.0
  • Constructor Details

    • AsyncEventBus

      public AsyncEventBus(String identifier, Executor executor)
      Creates a new AsyncEventBus that will use executor to dispatch events. Assigns identifier as the bus's name for logging purposes.
      Parameters:
      identifier - short name for the bus, for logging purposes.
      executor - Executor to use to dispatch events. It is the caller's responsibility to shut down the executor after the last event has been posted to this event bus.
    • AsyncEventBus

      public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler)
      Creates a new AsyncEventBus that will use executor to dispatch events.
      Parameters:
      executor - Executor to use to dispatch events. It is the caller's responsibility to shut down the executor after the last event has been posted to this event bus.
      subscriberExceptionHandler - Handler used to handle exceptions thrown from subscribers. See SubscriberExceptionHandler for more information.
      Since:
      16.0
    • AsyncEventBus

      public AsyncEventBus(Executor executor)
      Creates a new AsyncEventBus that will use executor to dispatch events.
      Parameters:
      executor - Executor to use to dispatch events. It is the caller's responsibility to shut down the executor after the last event has been posted to this event bus.