JourneyEventsConsumption.java

public void setOnJourneyBegin(Object journeyEvent) {
  subject.onNext(journeyEvent);
}

public Observable<Object> getOnJourneyEvent() {
  return subject;
}

public void setOnJourneyEnd(Object journeyEvent) {
  subject.onNext(journeyEvent);
}

public void setOnJourneyUpdate(Object journeyEvent) {
  subject.onNext(journeyEvent);
}