Uses of Interface
org.axonframework.messaging.eventstreaming.StreamingCondition

Packages that use StreamingCondition

Package	Description
org.axonframework.axonserver.connector.event
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventsourcing.eventstore.inmemory
org.axonframework.eventsourcing.eventstore.jpa	JPA Implementation of the EventStore.
org.axonframework.messaging.eventstreaming
org.axonframework.test.fixture

Uses of StreamingCondition in org.axonframework.axonserver.connector.event

Methods in org.axonframework.axonserver.connector.event with parameters of type StreamingCondition

Modifier and Type	Method	Description
static io.axoniq.axonserver.grpc.event.dcb.StreamEventsRequest	ConditionConverter.convertStreamingCondition(StreamingCondition condition)	Converts the given condition into a StreamEventsRequest.
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.stream(StreamingCondition condition)

Uses of StreamingCondition in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore with parameters of type StreamingCondition

Modifier and Type	Method	Description
MessageStream<EventMessage>	InterceptingEventStore.open(StreamingCondition condition, ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, ProcessingContext context)
MessageStream<EventMessage>	EventStorageEngine.stream(StreamingCondition condition)	Creates an infinite MessageStream of events matching the given condition.

Uses of StreamingCondition in org.axonframework.eventsourcing.eventstore.inmemory

Methods in org.axonframework.eventsourcing.eventstore.inmemory with parameters of type StreamingCondition

Modifier and Type	Method	Description
MessageStream<EventMessage>	InMemoryEventStorageEngine.stream(StreamingCondition condition)

Uses of StreamingCondition in org.axonframework.eventsourcing.eventstore.jpa

Methods in org.axonframework.eventsourcing.eventstore.jpa with parameters of type StreamingCondition

Modifier and Type	Method	Description
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.stream(StreamingCondition condition)

Uses of StreamingCondition in org.axonframework.messaging.eventstreaming

Methods in org.axonframework.messaging.eventstreaming that return StreamingCondition

Modifier and Type	Method	Description
static StreamingCondition	StreamingCondition.conditionFor(TrackingToken position, EventCriteria criteria)	Constructs a simple StreamingCondition that starts streaming from the given position, only returning events matching the given criteria.
StreamingCondition	StreamingCondition.or(EventCriteria criteria)	Combines the criteria() of this StreamingCondition with the given criteria.
static StreamingCondition	StreamingCondition.startingFrom(TrackingToken position)	Constructs a simple StreamingCondition that starts streaming from the given position.

Methods in org.axonframework.messaging.eventstreaming with parameters of type StreamingCondition

Modifier and Type	Method	Description
MessageStream<EventMessage>	StreamableEventSource.open(StreamingCondition condition, ProcessingContext context)	Open an event stream containing all events matching the given condition.

Uses of StreamingCondition in org.axonframework.test.fixture

Methods in org.axonframework.test.fixture with parameters of type StreamingCondition

Modifier and Type	Method	Description
MessageStream<EventMessage>	RecordingEventStore.open(StreamingCondition condition, ProcessingContext context)