Uses of Class
org.axonframework.messaging.core.AbstractMessageStream

Packages that use AbstractMessageStream

Package	Description
io.axoniq.framework.axonserver.connector.query	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.messaging.core	Classes related to message processing in Axon Framework.

Uses of AbstractMessageStream in io.axoniq.framework.axonserver.connector.query

Subclasses of AbstractMessageStream in io.axoniq.framework.axonserver.connector.query

Modifier and Type	Class	Description
class	AbstractQueryResponseMessageStream<T>	An abstract implementation of the MessageStream interface that wraps a ResultStream.
class	QueryResponseMessageStream	A MessageStream implementation that wraps an ResultStream of QueryResponses, using QueryConverter.
class	QueryUpdateMessageStream	A specialized implementation of AbstractQueryResponseMessageStream that processes a stream of QueryUpdate objects and transforms them into QueryResponseMessage instances.

Uses of AbstractMessageStream in org.axonframework.eventsourcing.eventstore

Subclasses of AbstractMessageStream in org.axonframework.eventsourcing.eventstore

Modifier and Type	Class	Description
final class	ContinuousMessageStream<E>	A MessageStream implementation that continuously fetches event messages from a configurable data source.

Uses of AbstractMessageStream in org.axonframework.messaging.core

Subclasses of AbstractMessageStream in org.axonframework.messaging.core

Modifier and Type	Class	Description
class	CloseCallbackMessageStream<M extends Message>	MessageStream implementation that invokes the given closeHandler once the stream is closed.
class	QueueMessageStream<M extends Message>	A MessageStream implementation backed by a BlockingQueue.