org.apache.ambari.server.utils

Class EventBusSynchronizer

java.lang.Object

org.apache.ambari.server.utils.EventBusSynchronizer

public class EventBusSynchronizer
extends Object

The EventBusSynchronizer is used to replace the AsyncEventBus used by Guava with a synchronous, serial EventBus instance. This enables testing that relies on testing the outcome of asynchronous events by executing the events on the current thread serially.

Constructor Summary

Constructors

Constructor and Description
EventBusSynchronizer()

Method Summary

Modifier and Type	Method and Description
static com.google.common.eventbus.EventBus	synchronizeAlertEventPublisher(com.google.inject.Injector injector) Force the EventBus from AlertEventPublisher to be serial and synchronous.
static void	synchronizeAmbariEventPublisher(com.google.inject.Binder binder) Force the EventBus from AmbariEventPublisher to be serial and synchronous.
static com.google.common.eventbus.EventBus	synchronizeAmbariEventPublisher(com.google.inject.Injector injector) Force the EventBus from AlertEventPublisher to be serial and synchronous.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventBusSynchronizer

public EventBusSynchronizer()

Method Detail

synchronizeAmbariEventPublisher

public static void synchronizeAmbariEventPublisher(com.google.inject.Binder binder)

Force the EventBus from AmbariEventPublisher to be serial and synchronous.

Parameters:

binder -

synchronizeAmbariEventPublisher

public static com.google.common.eventbus.EventBus synchronizeAmbariEventPublisher(com.google.inject.Injector injector)

Force the EventBus from AlertEventPublisher to be serial and synchronous. Also register the known listeners. Registering known listeners is necessary since the event bus was replaced.

Parameters:

injector -

synchronizeAlertEventPublisher

public static com.google.common.eventbus.EventBus synchronizeAlertEventPublisher(com.google.inject.Injector injector)

Force the EventBus from AlertEventPublisher to be serial and synchronous. Also register the known listeners. Registering known listeners is necessary since the event bus was replaced.

Parameters:

injector -