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

Packages that use StreamingCondition

Package	Description
org.axonframework.axonserver.connector.event	Part of the Axon Server Connector module.
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	Part of the Axon Eventsourcing module.
org.axonframework.eventsourcing.eventstore.jpa	Part of the Axon Eventsourcing module.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.
org.axonframework.test.fixture	Part of the Axon Test module.

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, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, @Nullable 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(@Nullable 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>	MultiStreamableEventSource.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StreamableEventSource.open(StreamingCondition condition, @Nullable 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, @Nullable ProcessingContext context)