@Test void testUsingLocalEventStoreOnOpeningStream() { testSubject.publish(new GenericDomainEventMessage<>("aggregateType", "aggregateId", 0, "Test1")); testSubject.openStream(null); assertWithin(1, TimeUnit.SECONDS, () -> assertEquals(1, eventStore.getEventsRequests().size())); assertFalse(eventStore.getEventsRequests().get(0).getForceReadFromLeader()); }
@Override public TrackingEventStream openStream(TrackingToken trackingToken) { return storageEngine().openStream(trackingToken); }
AxonServerEventStore extends AbstractEventStore { @Override public TrackingEventStream openStream(TrackingToken trackingToken) { return storageEngine().openStream(trackingToken); } }
AxonServerEventStore extends AbstractEventStore { @Override public TrackingEventStream openStream(TrackingToken trackingToken) { return storageEngine().openStream(trackingToken); } protected  AxonServerEventStore(Builder builder); }
AxonServerEventStore extends AbstractEventStore { @Override public TrackingEventStream openStream(TrackingToken trackingToken) { return storageEngine().openStream(trackingToken); } protected  AxonServerEventStore(Builder builder); static Builder builder(); @Override TrackingEventStream openStream(TrackingToken trackingToken); QueryResultStream query(String query, boolean liveUpdates); StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context); }
AxonServerEventStore extends AbstractEventStore { @Override public TrackingEventStream openStream(TrackingToken trackingToken) { return storageEngine().openStream(trackingToken); } protected  AxonServerEventStore(Builder builder); static Builder builder(); @Override TrackingEventStream openStream(TrackingToken trackingToken); QueryResultStream query(String query, boolean liveUpdates); StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context);  }