@Disabled("No supported in new connector, yet.") @Test void testUsingLocalEventStoreOnQueryingEvents() { testSubject.publish(new GenericDomainEventMessage<>("aggregateType", "aggregateId", 0, "Test1")); testSubject.query("", true); assertWithin(1, TimeUnit.SECONDS, () -> assertEquals(1, eventStore.getQueryEventsRequests().size())); assertFalse(eventStore.getQueryEventsRequests().get(0).getForceReadFromLeader()); }
public QueryResultStream query(String query, boolean liveUpdates) { return storageEngine().query(query, liveUpdates); }
AxonServerEventStore extends AbstractEventStore { public QueryResultStream query(String query, boolean liveUpdates) { return storageEngine().query(query, liveUpdates); } }
AxonServerEventStore extends AbstractEventStore { public QueryResultStream query(String query, boolean liveUpdates) { return storageEngine().query(query, liveUpdates); } protected  AxonServerEventStore(Builder builder); }
AxonServerEventStore extends AbstractEventStore { public QueryResultStream query(String query, boolean liveUpdates) { return storageEngine().query(query, liveUpdates); } 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 { public QueryResultStream query(String query, boolean liveUpdates) { return storageEngine().query(query, liveUpdates); } protected  AxonServerEventStore(Builder builder); static Builder builder(); @Override TrackingEventStream openStream(TrackingToken trackingToken); QueryResultStream query(String query, boolean liveUpdates); StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context);  }