EventDispatcher.useEventProcessor(RxEventProcessor.newInstance());

  EventDispatcher.useEventProcessor(EventProcessor.newInstance());

@Override
  public void onCreate() {

super.onCreate();

// register the event dispatcher in order to receive 

// events that are posted on the Bus.

EventDispatcher.register(this);

  
}

 @Override
  public void onDestroy() {

super.onDestroy();

// unregister the event dispatcher

EventDispatcher.unregister(this);

  
}

 @Override
  public void onCreate() {

super.onCreate();

// post an example event 

EventDispatcher.post(new ExampleEvent());

  
}

 @RxSubscribe
  public void onConsumeExampleEvent(ExampleEvent event) {

// do what you want with the incoming event
  
}

 /** 
 * This is an example empty event: remember to add the "Event" annotation!! 
 */
  @Event(type = Event.Type.UI)
  public class ExampleEvent {

  public ExampleEvent() {

  // empty constructor

}

  
}

private String mEventDispatcherTag;

 @Override
  public void onCreate() {

super.onCreate();

// retrieve the saved state, if present

if (savedInstanceState != null && savedInstanceState.containsKey("ett")) {

 this.mEventDispatcherTag = savedInstanceState.getString("ett");

}

// loadPoint() is used to handle events' saved state between configuration changes 

EventDispatcher.loadPoint(this, this.mEventDispatcherTag);

  
}

 @Override
  protected void onSaveInstanceState(Bundle outState) {

super.onSaveInstanceState(outState);

// save the EventDispatcher's tag

outState.putString("ett", mEventDispatcherTag);

  
}

 @Override
  public void onDestroy() {

super.onDestroy();

// save point is used to save the state in order to restore it later, after the configuration change.

this.mEventDispatcherTag = EventDispatcher.savePoint(this);

  
}

 public interface EventProcessor {

 /** 

* Registers a given Object on both Buses 

* 

* @param o Object to register on the Buses 

*/

void onRegister(Object o);

  /** 

* Unregisters a given Object from both Buses 

* 

* @param o Object to unregister from the Buses 

*/

void onUnregister(Object o);

 /** 

* After checking whether the object being posted is annotated with the {
@link Event
}
 Annotation, 

* it will be placed in the corresponding queue and such queue will be then sorted by {
@link Event.Priority
}
. 

* <p> 

*
  <b>NOTE: if an object being posted has not been annotated with the {
@link Event
}
 Annotation it will be disregarded!!!</b> 

* </p> 

* 

* @param o the Object we want to post as an event 

*/

void onPost(Object o);

  /** 

* This method return a string used by {
@link EventProcessor
}
 to save the state of the object in configuration changes.<br> 

* You should use the string returned by this method with {
@code EventDispatcher.loadPoint()
}
<br> 

* This method must be called before {
@code EventDispatcher.unregister(...)
}
 (in {
@code OnPause(...)
}
 method for example) 

* <p> 

* <b>NOTE: this string should be saved on instance state in Activity and retrieved when it restart on OnCreate(...) method</b> 

* </p> 

* 

* @param object 

* @return 

*/

String onSavePoint(Object object);

  /** 

* This method load the configuration variables used by {
@link EventDispatcher
}
 to handle the configuration changes.<br> 

* You should use this method in pair with {
@code EventDispatcher.savePoint(...)
}
.<br> 

* This method must be called before {
@code EventDispatcher.register(...)
}
 (in {
@code OnResume(...)
}
 method for example)<br> 

* 

* @param object 

* 

*/

void onLoadPoint(Object object, String key);

  
}