@Test void getEvent() throws EventStreamException, QueryException { assertFalse(this.defaultStore.getEvent("id").isPresent()); when(this.store.getEvent("id")).thenReturn(Optional.of(EVENT)); assertSame(EVENT, this.defaultStore.getEvent("id").get()); when(this.store.getEvent("id")).thenReturn(Optional.empty()); assertFalse(this.defaultStore.getEvent("id").isPresent()); when(this.legacyStore.getEvent("id")).thenReturn(Optional.of(EVENT)); assertFalse(this.defaultStore.getEvent("id").isPresent()); }
@Override public Optional<Event> getEvent(String eventId) throws EventStreamException { Optional<Event> event = Optional.empty(); if (this.store != null) { event = this.store.getEvent(eventId); } else if (this.legacyStore != null) { event = this.legacyStore.getEvent(eventId); } return event; }
DefaultEventStore implements EventStore, Initializable { @Override public Optional<Event> getEvent(String eventId) throws EventStreamException { Optional<Event> event = Optional.empty(); if (this.store != null) { event = this.store.getEvent(eventId); } else if (this.legacyStore != null) { event = this.legacyStore.getEvent(eventId); } return event; } }
DefaultEventStore implements EventStore, Initializable { @Override public Optional<Event> getEvent(String eventId) throws EventStreamException { Optional<Event> event = Optional.empty(); if (this.store != null) { event = this.store.getEvent(eventId); } else if (this.legacyStore != null) { event = this.legacyStore.getEvent(eventId); } return event; }  }
DefaultEventStore implements EventStore, Initializable { @Override public Optional<Event> getEvent(String eventId) throws EventStreamException { Optional<Event> event = Optional.empty(); if (this.store != null) { event = this.store.getEvent(eventId); } else if (this.legacyStore != null) { event = this.legacyStore.getEvent(eventId); } return event; }  @Override void initialize(); @Override CompletableFuture<Event> saveEvent(Event event); @Override CompletableFuture<Event> prefilterEvent(Event event); @Override CompletableFuture<Optional<Event>> deleteEvent(String eventId); @Override CompletableFuture<Optional<Event>> deleteEvent(Event event); @Override CompletableFuture<EventStatus> saveEventStatus(EventStatus status); @Override CompletableFuture<EventStatus> saveMailEntityEvent(EntityEvent event); @Override CompletableFuture<Optional<EventStatus>> deleteEventStatus(EventStatus status); @Override CompletableFuture<Void> deleteEventStatuses(String entityId, Date date); @Override CompletableFuture<Optional<EventStatus>> deleteMailEntityEvent(EntityEvent event); @Override Optional<Event> getEvent(String eventId); @Override EventSearchResult search(EventQuery query); @Override EventSearchResult search(EventQuery query, Set<String> fields); }
DefaultEventStore implements EventStore, Initializable { @Override public Optional<Event> getEvent(String eventId) throws EventStreamException { Optional<Event> event = Optional.empty(); if (this.store != null) { event = this.store.getEvent(eventId); } else if (this.legacyStore != null) { event = this.legacyStore.getEvent(eventId); } return event; }  @Override void initialize(); @Override CompletableFuture<Event> saveEvent(Event event); @Override CompletableFuture<Event> prefilterEvent(Event event); @Override CompletableFuture<Optional<Event>> deleteEvent(String eventId); @Override CompletableFuture<Optional<Event>> deleteEvent(Event event); @Override CompletableFuture<EventStatus> saveEventStatus(EventStatus status); @Override CompletableFuture<EventStatus> saveMailEntityEvent(EntityEvent event); @Override CompletableFuture<Optional<EventStatus>> deleteEventStatus(EventStatus status); @Override CompletableFuture<Void> deleteEventStatuses(String entityId, Date date); @Override CompletableFuture<Optional<EventStatus>> deleteMailEntityEvent(EntityEvent event); @Override Optional<Event> getEvent(String eventId); @Override EventSearchResult search(EventQuery query); @Override EventSearchResult search(EventQuery query, Set<String> fields);  }