private static void replaceEventBus(Class<?> eventPublisherClass,
      Object instance, EventBus eventBus) {

    try {
      Field field = eventPublisherClass.getDeclaredField("m_eventBus");
      field.setAccessible(true);
      field.set(instance, eventBus);
    } catch (Exception exception) {
      throw new RuntimeException(exception);
    }
  }
Register the normal listeners with the replaced synchronous bus.

@param injector
@param synchronizedBus
ambari-server/src/main/java/org/apache/ambari/server/utils/EventBusSynchronizer.java