@Test void testCreateStreamableMessageSourceForContext() { assertNotNull(testSubject.createStreamableMessageSourceForContext("some-context")); }
public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context) { return new AxonServerMessageSource(storageEngine().createInstanceForContext(context)); }
AxonServerEventStore extends AbstractEventStore { public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context) { return new AxonServerMessageSource(storageEngine().createInstanceForContext(context)); } }
AxonServerEventStore extends AbstractEventStore { public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context) { return new AxonServerMessageSource(storageEngine().createInstanceForContext(context)); } protected  AxonServerEventStore(Builder builder); }
AxonServerEventStore extends AbstractEventStore { public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context) { return new AxonServerMessageSource(storageEngine().createInstanceForContext(context)); } 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 StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context) { return new AxonServerMessageSource(storageEngine().createInstanceForContext(context)); } protected  AxonServerEventStore(Builder builder); static Builder builder(); @Override TrackingEventStream openStream(TrackingToken trackingToken); QueryResultStream query(String query, boolean liveUpdates); StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context);  }