Bus bus = ReactiveBus.create(); // creating thread safe instance of event bus

Disposable observer = bus.receive().subscribe(new Consumer<Event>() {
    @Override public void accept(Event event) {
      // handle event here
    }
  });

// send a message only (with random id)
bus.send(Event.name("my event 1").build());

// send some data (with random id)
bus.send(Event.name("my event 2").data(serializableObject).build());

// send id, name and some data
bus.send(Event.id("myId").name("my event 3").data(serializableObject).build());

observer.dispose(); // after disposal, observer will stop receiving new events