Uses of Interface
org.axonframework.messaging.MessageStream

Packages that use MessageStream

Package	Description
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.kafka.eventhandling.consumer
org.axonframework.messaging	Classes related to message processing in Axon Framework.

Uses of MessageStream in org.axonframework.eventsourcing.eventstore

Subinterfaces of MessageStream in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface and Description
interface	TrackingEventStream Describes a stream of TrackedEventMessages.

Uses of MessageStream in org.axonframework.kafka.eventhandling.consumer

Classes in org.axonframework.kafka.eventhandling.consumer that implement MessageStream

Modifier and Type	Class and Description
class	KafkaMessageStream Create message stream from a specific kafka topic.

Methods in org.axonframework.kafka.eventhandling.consumer that return MessageStream

Modifier and Type	Method and Description
MessageStream<TrackedEventMessage<?>>	KafkaMessageSource.openStream(TrackingToken trackingToken)
MessageStream<TrackedEventMessage<?>>	Fetcher.start(KafkaTrackingToken token) Open a stream of messages, starting at the position indicated by the given token.
MessageStream<TrackedEventMessage<?>>	AsyncFetcher.start(KafkaTrackingToken token)

Uses of MessageStream in org.axonframework.messaging

Methods in org.axonframework.messaging that return MessageStream

Modifier and Type	Method and Description
MessageStream<M>	StreamableMessageSource.openStream(TrackingToken trackingToken) Open a stream containing all messages since given tracking token.

Methods in org.axonframework.messaging with parameters of type MessageStream

Modifier and Type	Method and Description
static <M extends Message<?>> Stream<M>	StreamUtils.asStream(MessageStream<M> messageStream) Convert the given messageStream to a regular java Stream of messages.