JourneyEventBusSubscribe.java

JourneyEventBus.getInstance().getOnJourneyEvent()
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(new Consumer<Object>() {
     @Override
     public void accept(Object o) throws Exception {
       if (o instanceof BeginJourneyEvent) {
          Snackbar.make(linearLayout, "Journey has started",
                Snackbar.LENGTH_SHORT).show();
       } else if (o instanceof EndJourneyEvent) {
          Snackbar.make(linearLayout, "Journey has ended",
                Snackbar.LENGTH_SHORT).show();
       } else if (o instanceof CurrentJourneyEvent) {
          /*
          * This can be used to receive the current location update of the car
          */
          //Log.d(TAG,"Current "+((CurrentJourneyEvent) o).getCurrentLatLng());
       }
    }
});