Uses of Interface
org.axonframework.messaging.core.MessageStream

Packages that use MessageStream

Package	Description
io.axoniq.framework.axonserver.connector.event	Part of the Axon Server Connector module.
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.eventstreaming	Part of the Axoniq Messaging folder.
io.axoniq.framework.messaging.multitenancy.api	Contains the multi-tenancy API, like the tenant descriptor, tenant provider, and tenant resolution contracts.
io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.eventsourcing	Package containing multitenancy support for event sourcing components.
io.axoniq.framework.messaging.multitenancy.queryhandling	Package containing multitenancy support for query components.
io.axoniq.framework.messaging.queryhandling.distributed	Part of the Axon Messaging module.
io.axoniq.framework.messaging.queryhandling.distributed.tracing	Internal delegating tracing decorator for the distributed QueryBusConnector.
io.axoniq.framework.messaging.transformation	Part of the Axoniq Messaging folder.
io.axoniq.framework.messaging.transformation.events	Part of the Axoniq Messaging folder.
io.axoniq.framework.postgresql	Postgres extension main package.
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.eventsourcing.eventstore.tracing	Event-store tracing decorators and event-sourcing-specific SpanAttributesProvider implementations.
org.axonframework.extension.spring.authorization	Part of the Axon Extension module.
org.axonframework.messaging.commandhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.core.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.core.retry	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling	Package for query handling components in Axon Framework.
org.axonframework.messaging.queryhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.tracing	Tracing decorators for query handling components.
org.axonframework.messaging.tracing	The tracing API of Axon Framework: SpanFactory, Span, SpanScope, and SpanAttributesProvider, plus the logging and no-op factory implementations.
org.axonframework.test.fixture	Part of the Axon Test module.

Uses of MessageStream in io.axoniq.framework.axonserver.connector.event

Classes in io.axoniq.framework.axonserver.connector.event that implement MessageStream

Modifier and Type	Class	Description
class	SourcingEventMessageStream	A MessageStream implementation backed by a ResultStream of SourceEventsResponses from Axon Server, translating the SourceEventsResponses into EventMessages as it moves along.
class	StreamingEventMessageStream	A MessageStream implementation backed by a ResultStream of StreamEventsResponses from Axon Server, translating the StreamEventsResponses into EventMessages as it moves along.

Methods in io.axoniq.framework.axonserver.connector.event that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AxonServerEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.stream(StreamingCondition condition)

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

Classes in io.axoniq.framework.axonserver.connector.query that implement MessageStream

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.

Methods in io.axoniq.framework.axonserver.connector.query that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in io.axoniq.framework.messaging.eventstreaming

Methods in io.axoniq.framework.messaging.eventstreaming that return MessageStream

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

Uses of MessageStream in io.axoniq.framework.messaging.multitenancy.api

Methods in io.axoniq.framework.messaging.multitenancy.api that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	AttachTenantDescriptorDispatchInterceptor.interceptOnDispatch(Message message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<Message> interceptorChain)
MessageStream<?>	RegisterTenantDescriptorHandlerInterceptor.interceptOnHandle(Message message, ProcessingContext context, MessageHandlerInterceptorChain<Message> interceptorChain)

Uses of MessageStream in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)	Resolves the connector for the current tenant and subsequently dispatches the given query to it.
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)	Resolves the connector for the current tenant and subsequently dispatches the given subscription query to it.

Uses of MessageStream in io.axoniq.framework.messaging.multitenancy.eventsourcing

Methods in io.axoniq.framework.messaging.multitenancy.eventsourcing that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	MultiTenantEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	MultiTenantEventStorageEngine.stream(StreamingCondition condition)

Uses of MessageStream in io.axoniq.framework.messaging.multitenancy.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.queryhandling that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)	Dispatches the given query for the tenant resolved from it.
MessageStream<SubscriptionQueryUpdateMessage>	TenantAwareQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in io.axoniq.framework.messaging.queryhandling.distributed

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	DistributedQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBusConnector.Handler.query(QueryMessage query)	Handles the incoming query message.
MessageStream<QueryResponseMessage>	QueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)	Sends the given query to the remote QueryBus.
MessageStream<SubscriptionQueryUpdateMessage>	DistributedQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	DistributedQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)	Sends the given query to the remote QueryBus.

Uses of MessageStream in io.axoniq.framework.messaging.queryhandling.distributed.tracing

Methods in io.axoniq.framework.messaging.queryhandling.distributed.tracing that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TracingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	TracingQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in io.axoniq.framework.messaging.transformation

Methods in io.axoniq.framework.messaging.transformation that return MessageStream

Modifier and Type	Method	Description
MessageStream<? extends M>	MessageTransformation.transform(M message, TransformationContext context)	Transforms a message into zero or more messages of the same type.

Uses of MessageStream in io.axoniq.framework.messaging.transformation.events

Methods in io.axoniq.framework.messaging.transformation.events that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	TransformingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	EventTransformerChain.transform(MessageStream<? extends EventMessage> stream, @Nullable ProcessingContext context, MessageConverter converter, MessageTypeResolver messageTypeResolver)	Applies the chain to every event in the given stream at read time.

Methods in io.axoniq.framework.messaging.transformation.events with parameters of type MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	EventTransformerChain.transform(MessageStream<? extends EventMessage> stream, @Nullable ProcessingContext context, MessageConverter converter, MessageTypeResolver messageTypeResolver)	Applies the chain to every event in the given stream at read time.

Uses of MessageStream in io.axoniq.framework.postgresql

Methods in io.axoniq.framework.postgresql that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	PostgresqlEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	PostgresqlEventStorageEngine.stream(StreamingCondition condition)

Uses of MessageStream in org.axonframework.eventsourcing.eventstore

Classes in org.axonframework.eventsourcing.eventstore that implement MessageStream

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

Methods in org.axonframework.eventsourcing.eventstore that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	InterceptingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition)
MessageStream<? extends EventMessage>	DefaultEventStoreTransaction.source(SourcingCondition condition, @Nullable Consumer<Position> resumePositionCallback)
default MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition)	Creates a finite MessageStream of events matching the given condition.
MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)	Creates a finite MessageStream of events matching the given condition, carrying along the active ProcessingContext.
default MessageStream<? extends EventMessage>	EventStoreTransaction.source(SourcingCondition condition)	Sources a MessageStream of type EventMessage based on the given condition that can be used to rehydrate a model.
MessageStream<? extends EventMessage>	EventStoreTransaction.source(SourcingCondition condition, @Nullable Consumer<Position> resumePositionCallback)	Sources a MessageStream of type EventMessage based on the given condition, optionally invoking the given resume position callback.
MessageStream<EventMessage>	SnapshotCapableEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	EventStorageEngine.stream(StreamingCondition condition)	Creates an infinite MessageStream of events matching the given condition.
MessageStream<EventMessage>	SnapshotCapableEventStorageEngine.stream(StreamingCondition condition)

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

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	InMemoryEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	InMemoryEventStorageEngine.stream(StreamingCondition condition)

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

Methods in org.axonframework.eventsourcing.eventstore.jpa that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.stream(StreamingCondition condition)

Uses of MessageStream in org.axonframework.eventsourcing.eventstore.tracing

Methods in org.axonframework.eventsourcing.eventstore.tracing that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	TracingEventStore.open(StreamingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	TracingEventStorageEngine.source(SourcingCondition condition, @Nullable ProcessingContext context)
MessageStream<EventMessage>	TracingEventStorageEngine.stream(StreamingCondition condition)

Uses of MessageStream in org.axonframework.extension.spring.authorization

Methods in org.axonframework.extension.spring.authorization that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	MessageAuthorizationDispatchInterceptor.interceptOnDispatch(T message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<T> interceptorChain)
MessageStream<?>	MessageAuthorizationHandlerInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> interceptorChain)

Uses of MessageStream in org.axonframework.messaging.commandhandling.interception

Methods in org.axonframework.messaging.commandhandling.interception that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	CommandSequencingInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> interceptorChain)
MessageStream<?>	CommandMessageHandlerInterceptorChain.proceed(CommandMessage command, ProcessingContext context)

Uses of MessageStream in org.axonframework.messaging.core

Subinterfaces of MessageStream in org.axonframework.messaging.core

Modifier and Type	Interface	Description
static interface	MessageStream.Empty<M extends Message>	A MessageStream implementation that completes normally or with an error without returning any elements.
static interface	MessageStream.Single<M extends Message>	A MessageStream implementation that returns at most a single result before completing.

Classes in org.axonframework.messaging.core that implement MessageStream

Modifier and Type	Class	Description
class	AbstractMessageStream<M extends Message>	Abstract base implementation of MessageStream that provides full state management for consumption, completion, error propagation, closing, and callback coordination.
class	CloseCallbackMessageStream<M extends Message>	MessageStream implementation that invokes the given closeHandler once the stream is closed.
class	DelayedMessageStream<M extends Message>	An implementation of the MessageStream that wraps a stream that will become available asynchronously.
class	DelegatingMessageStream<DM extends Message,RM extends Message>	Abstract implementation of an MessageStream that delegates calls to a given delegate.
class	LazyMessageStream<M extends Message>	A MessageStream that defers creation of its delegate stream until the first message is requested.
class	MergedMessageStream<M extends Message>	A MessageStream implementation that merges two underlying message streams into a single stream.
class	QueueMessageStream<M extends Message>	A MessageStream implementation backed by a BlockingQueue.

Methods in org.axonframework.messaging.core that return MessageStream

Modifier and Type	Method	Description
static <M extends Message> MessageStream<M>	FluxUtils.asMessageStream(reactor.core.publisher.Flux<M> flux)	Create a stream that provides the Messages returned by the given flux, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	FluxUtils.asMessageStream(reactor.core.publisher.Flux<M> flux, Function<M,Context> contextSupplier)	Create a stream that provides the Messages returned by the given flux, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
default <T extends Message> MessageStream<T>	MessageStream.cast()	Casts this stream to the given type.
default MessageStream<M>	MessageStream.concatWith(Supplier<MessageStream<M>> next)	Returns a stream that concatenates this stream with a stream created lazily by the given next supplier, if this stream completes successfully.
default MessageStream<M>	MessageStream.concatWith(MessageStream<? extends M> other)	Returns a stream that concatenates this stream with the given other stream, if this stream completes successfully.
default MessageStream<M>	MessageStream.Empty.concatWith(MessageStream<? extends M> other)
static <M extends Message> MessageStream<M>	DelayedMessageStream.create(CompletableFuture<? extends MessageStream<M>> delegate)	Creates a stream that delays actions to its delegate when it becomes available.
protected MessageStream<DM>	DelegatingMessageStream.delegate()	Returns the delegate as provided in the constructor.
default MessageStream<M>	MessageStream.filter(Predicate<MessageStream.Entry<M>> filter)	Returns a stream that will filter entries based on the given filter.
default <N extends Message> MessageStream<N>	MessageStream.flatMap(Function<? super MessageStream.Entry<M>,? extends MessageStream<? extends N>> mapper)	Returns a stream that maps each entry from this stream to an inner MessageStream using the given mapper, then concatenates all inner stream entries in order.
static <M extends Message> MessageStream<M>	MessageStream.fromItems(M... items)	Creates a MessageStream that provides the given items and then completes.
static <M extends Message> MessageStream<M>	MessageStream.fromIterable(Iterable<? extends M> iterable)	Create a stream that provides the Messages returned by the given iterable, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	MessageStream.fromIterable(Iterable<? extends M> iterable, Function<? super M,? extends Context> contextSupplier)	Create a stream that provides the Messages returned by the given iterable, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
static <M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends M> stream)	Create a stream that provides the Messages returned by the given stream, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends M> stream, Function<? super M,? extends Context> contextSupplier)	Create a stream that provides the Messages returned by the given stream, automatically wrapped in an MessageStream.Entry with the resulting Context from the contextSupplier.
static <T, M extends Message> MessageStream<M>	MessageStream.fromStream(Stream<? extends T> stream, Function<? super T,? extends M> messageSupplier, Function<? super T,? extends Context> contextSupplier)	Create a stream that provides the items of type T returned by the given stream, automatically wrapped in an MessageStream.Entry with the resulting Message and Context from the messageSupplier and the contextSupplier respectively.
MessageStream<? extends Message>	MessageHandlingExceptionHandler.handle(M message, ProcessingContext context, Throwable error)	Called when a message handler throws an exception.
MessageStream<?>	MessageDispatchInterceptor.interceptOnDispatch(M message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<M> interceptorChain)	Intercepts a given message on dispatching.
MessageStream<?>	MessageHandlerInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> interceptorChain)	Intercepts a given message on handling before reaching the designated MessageHandler.
default <RM extends Message> MessageStream<RM>	MessageStream.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)	Returns a stream that maps each entry from this stream using given mapper function into an entry carrying a MessageEntry with a Message of type RM.
default <RM extends Message> MessageStream<RM>	MessageStream.mapMessage(Function<M,RM> mapper)	Returns a stream that maps each message from the entries in this stream using the given mapper function.
default <N extends Message> MessageStream<N>	MessageStream.mapMulti(BiConsumer<? super MessageStream.Entry<M>,? super Consumer<MessageStream.Entry<N>>> mapper)	Returns a stream that maps each entry from this stream to zero or more output entries of type N, using the given mapper.
default MessageStream<M>	MessageStream.onClose(Runnable closeHandler)	Returns a stream that, when it is either explicitly closed using close(), or when this stream completes (regularly or with an error) calls the given closeHandler.
default MessageStream<M>	MessageStream.onComplete(Runnable completeHandler)	Returns a stream that invokes the given completeHandler when the stream completes normally.
default MessageStream<M>	MessageStream.onErrorContinue(Function<Throwable,MessageStream<? extends M>> onError)	Returns a stream that, when this stream completes with an error, continues reading from the stream provided by given onError function.
default MessageStream<M>	MessageStream.onNext(Consumer<MessageStream.Entry<M>> onNext)	Invokes the given onNext each time an entry is consumed from this stream.
MessageStream<?>	DefaultMessageDispatchInterceptorChain.proceed(M message, @Nullable ProcessingContext context)
MessageStream<?>	MessageDispatchInterceptorChain.proceed(M message, @Nullable ProcessingContext context)	Signals this interceptor chain to continue processing the message.
MessageStream<?>	MessageHandlerInterceptorChain.proceed(M message, ProcessingContext context)	Signals this interceptor chain to continue processing the message.

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

Modifier and Type	Method	Description
default MessageStream<M>	MessageStream.concatWith(MessageStream<? extends M> other)	Returns a stream that concatenates this stream with the given other stream, if this stream completes successfully.
default MessageStream<M>	MessageStream.Empty.concatWith(MessageStream<? extends M> other)
static <M extends Message> AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.FetchResult.of(MessageStream<M> delegate)	Creates a FetchResult reflecting the current observable state of the given MessageStream.
static <M extends Message> reactor.core.publisher.Flux<MessageStream.Entry<M>>	FluxUtils.of(MessageStream<? extends M> source)	Creates a Flux containing the entries provided by the given source.
static <M extends Message, R> CompletableFuture<@Nullable R>	MessageStreamUtils.reduce(MessageStream<M> source, @Nullable R identity, BiFunction<@Nullable R,? super MessageStream.Entry<M>,@Nullable R> accumulator)	Returns a CompletableFuture that completes with the given reduction of messages read from the source.

Method parameters in org.axonframework.messaging.core with type arguments of type MessageStream

Modifier and Type	Method	Description
default MessageStream<M>	MessageStream.concatWith(Supplier<MessageStream<M>> next)	Returns a stream that concatenates this stream with a stream created lazily by the given next supplier, if this stream completes successfully.
static <M extends Message> MessageStream<M>	DelayedMessageStream.create(CompletableFuture<? extends MessageStream<M>> delegate)	Creates a stream that delays actions to its delegate when it becomes available.
default <N extends Message> MessageStream<N>	MessageStream.flatMap(Function<? super MessageStream.Entry<M>,? extends MessageStream<? extends N>> mapper)	Returns a stream that maps each entry from this stream to an inner MessageStream using the given mapper, then concatenates all inner stream entries in order.
default MessageStream<M>	MessageStream.onErrorContinue(Function<Throwable,MessageStream<? extends M>> onError)	Returns a stream that, when this stream completes with an error, continues reading from the stream provided by given onError function.
static <M extends Message> org.reactivestreams.Publisher<M>	FluxUtils.streamToPublisher(Supplier<MessageStream<M>> stream)	Converts a Supplier of MessageStream into a reactor-core Publisher.

Constructors in org.axonframework.messaging.core with parameters of type MessageStream

Modifier	Constructor	Description
	CloseCallbackMessageStream(MessageStream<M> delegate, Runnable closeHandler)	Creates an instance of the CloseCallbackMessageStream, calling the given closeHandler once this stream is closed, or the given delegate completes.
	DelegatingMessageStream(MessageStream<DM> delegate)	Constructs the DelegatingMessageStream with given delegate to receive calls.
	MergedMessageStream(Comparator<MessageStream.Entry<M>> comparator, MessageStream<M> first, MessageStream<M> second)	Constructs a MergedMessageStream that merges two message streams based on the given comparator.

Constructor parameters in org.axonframework.messaging.core with type arguments of type MessageStream

Modifier	Constructor	Description
	DefaultMessageDispatchInterceptorChain(Collection<MessageDispatchInterceptor<? super M>> interceptors, BiFunction<? super M,ProcessingContext,MessageStream<?>> terminal)	Constructs a DefaultMessageDispatchInterceptorChain from the given interceptors, invoking the given terminal operation when reaching the end of the interceptor chain.
	LazyMessageStream(Supplier<MessageStream<M>> supplier)	Constructs a LazyMessageStream backed by the given supplier.

Uses of MessageStream in org.axonframework.messaging.core.annotation

Methods in org.axonframework.messaging.core.annotation that return MessageStream

Modifier and Type	Method	Description
default MessageStream<?>	MessageStreamResolver.apply(@Nullable Object result)	Resolves the given result without knowing which type of Message the handler is subscribed for, and thus how many Messages it may produce.
MessageStream<?>	MessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)	Handles the given message within the given context by invoking the appropriate method on given target.
MessageStream<?>	MethodInvokingMessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)
MessageStream<?>	WrappedMessageHandlingMember.handle(Message message, ProcessingContext context, @Nullable T target)
MessageStream<?>	MessageStreamResolver.resolve(@Nullable Object result, Class<? extends Message> messageType)	Resolves the given result of a handler subscribed for the given messageType into a MessageStream.
static MessageStream<?>	MessageStreamResolverUtils.resolveToSingleStream(@Nullable Object result, MessageTypeResolver typeResolver)	Resolves the given result into a MessageStream carrying at most one Message, using the typeResolver when that Message is constructed to define the MessageType.
static MessageStream<?>	MessageStreamResolverUtils.resolveToStream(@Nullable Object result, MessageTypeResolver typeResolver)	Resolves the given result into a MessageStream that may carry several Messages, using the typeResolver when a Message is constructed to define the MessageType.

Method parameters in org.axonframework.messaging.core.annotation with type arguments of type MessageStream

Modifier and Type	Method	Description
<T> Optional<MessageHandlingMember<T>>	AnnotatedMessageHandlingMemberDefinition.createHandler(Class<T> declaringType, Method method, ParameterResolverFactory parameterResolverFactory, Function<Object,MessageStream<?>> messageStreamResolver)
<T> Optional<MessageHandlingMember<T>>	HandlerDefinition.createHandler(Class<T> declaringType, Method method, ParameterResolverFactory parameterResolverFactory, Function<Object,MessageStream<?>> messageStreamResolver)	Create a MessageHandlingMember for the given method method.
<T> Optional<MessageHandlingMember<T>>	MultiHandlerDefinition.createHandler(Class<T> declaringType, Method method, ParameterResolverFactory parameterResolverFactory, Function<Object,MessageStream<?>> messageStreamResolver)

Constructor parameters in org.axonframework.messaging.core.annotation with type arguments of type MessageStream

Modifier	Constructor	Description
	MethodInvokingMessageHandlingMember(Method method, Class<? extends Message> messageType, Class<?> explicitPayloadType, ParameterResolverFactory parameterResolverFactory, Function<Object,MessageStream<?>> returnTypeConverter)	Initializes a new instance that will invoke the given executable (method) on a target to handle a message of the given messageType.

Uses of MessageStream in org.axonframework.messaging.core.interception

Methods in org.axonframework.messaging.core.interception that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	BeanValidationInterceptor.interceptOnDispatch(M message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<M> dispatchInterceptorChain)
MessageStream<?>	CorrelationDataInterceptor.interceptOnDispatch(M message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<M> chain)
MessageStream<?>	LoggingInterceptor.interceptOnDispatch(M message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<M> interceptorChain)
MessageStream<?>	BeanValidationInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> handlerInterceptorChain)
MessageStream<?>	CorrelationDataInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> chain)
MessageStream<?>	LoggingInterceptor.interceptOnHandle(M message, ProcessingContext context, MessageHandlerInterceptorChain<M> interceptorChain)

Uses of MessageStream in org.axonframework.messaging.core.interception.annotation

Methods in org.axonframework.messaging.core.interception.annotation that return MessageStream

Modifier and Type	Method	Description
static <M extends Message> MessageStream<?>	InterceptorChainParameterResolverFactory.callWithInterceptorChain(ProcessingContext processingContext, MessageHandlerInterceptorChain<M> interceptorChain, Function<ProcessingContext,MessageStream<?>> action)	Invoke the given action with the given interceptorChain being available for parameter injection.
MessageStream<?>	ChainedMessageHandlerInterceptorMember.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
MessageStream<?>	MessageHandlerInterceptorMemberChain.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
MessageStream<?>	NoMoreInterceptors.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)

Method parameters in org.axonframework.messaging.core.interception.annotation with type arguments of type MessageStream

Modifier and Type	Method	Description
static <M extends Message> MessageStream<?>	InterceptorChainParameterResolverFactory.callWithInterceptorChain(ProcessingContext processingContext, MessageHandlerInterceptorChain<M> interceptorChain, Function<ProcessingContext,MessageStream<?>> action)	Invoke the given action with the given interceptorChain being available for parameter injection.

Uses of MessageStream in org.axonframework.messaging.core.retry

Methods in org.axonframework.messaging.core.retry that return MessageStream

Modifier and Type	Method	Description
MessageStream<R>	RetryScheduler.Dispatcher.dispatch(M message, @Nullable ProcessingContext processingContext)
<M extends Message, R extends Message> MessageStream<R>	AsyncRetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)
<M extends Message, R extends Message> MessageStream<R>	RetryScheduler.scheduleRetry(M message, @Nullable ProcessingContext processingContext, Throwable cause, RetryScheduler.Dispatcher<M,R> dispatcher)	Schedules the given message to retry dispatching using the given dispatching function.

Uses of MessageStream in org.axonframework.messaging.eventhandling.interception

Methods in org.axonframework.messaging.eventhandling.interception that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	EventMessageHandlerInterceptorChain.proceed(EventMessage event, ProcessingContext context)

Uses of MessageStream in org.axonframework.messaging.eventstreaming

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

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

Uses of MessageStream in org.axonframework.messaging.monitoring.interception

Methods in org.axonframework.messaging.monitoring.interception that return MessageStream

Modifier and Type	Method	Description
MessageStream<?>	MonitoringEventDispatchInterceptor.interceptOnDispatch(EventMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<EventMessage> interceptorChain)
MessageStream<?>	MonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain)
MessageStream<?>	MonitoringCommandHandlerInterceptor.interceptOnHandle(CommandMessage message, ProcessingContext context, MessageHandlerInterceptorChain<CommandMessage> interceptorChain)
MessageStream<?>	MonitoringEventHandlerInterceptor.interceptOnHandle(EventMessage message, ProcessingContext context, MessageHandlerInterceptorChain<EventMessage> interceptorChain)
MessageStream<?>	MonitoringQueryHandlerInterceptor.interceptOnHandle(QueryMessage message, ProcessingContext context, MessageHandlerInterceptorChain<QueryMessage> interceptorChain)

Uses of MessageStream in org.axonframework.messaging.queryhandling

Methods in org.axonframework.messaging.queryhandling that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	QueryHandler.handle(QueryMessage query, ProcessingContext context)	Handles the given query within the given context.
MessageStream<QueryResponseMessage>	QueryHandlingExceptionHandler.handle(QueryMessage query, ProcessingContext context, Throwable error)	Called when a query handler throws an exception.
MessageStream<QueryResponseMessage>	SimpleQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.query(QueryMessage query, @Nullable ProcessingContext context)	Dispatch the given query to a QueryHandler subscribed to the given query's query name, returning a MessageStream of responses to the given query.
MessageStream<QueryResponseMessage>	SimpleQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	QueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)	Subscribes the given query with the given updateBufferSize, and returns the MessageStream that provides the update of the subscription query.
MessageStream<SubscriptionQueryUpdateMessage>	SimpleQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)	Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.
MessageStream<QueryResponseMessage>	SimpleQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in org.axonframework.messaging.queryhandling.annotation

Methods in org.axonframework.messaging.queryhandling.annotation that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	AnnotatedQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)

Uses of MessageStream in org.axonframework.messaging.queryhandling.interception

Methods in org.axonframework.messaging.queryhandling.interception that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	InterceptingQueryHandlingComponent.handle(QueryMessage query, ProcessingContext processingContext)
MessageStream<?>	QueryMessageHandlerInterceptorChain.proceed(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in org.axonframework.messaging.queryhandling.tracing

Methods in org.axonframework.messaging.queryhandling.tracing that return MessageStream

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TracingQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	TracingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	TracingQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of MessageStream in org.axonframework.messaging.tracing

Methods in org.axonframework.messaging.tracing that return MessageStream

Modifier and Type	Method	Description
default <M extends Message> MessageStream<M>	Span.branchStream(@Nullable ProcessingContext context, Function<@Nullable ProcessingContext,MessageStream<M>> operation)	Runs the given MessageStream-producing operation as a branch-scoped span: starts this span, hands the operation a context branch carrying this span's scope (via SpanScope.addToContext(ProcessingContext, SpanScope)) so the operation's own children -- including those created in asynchronous continuations -- parent under this span, executes the operation's synchronous frame within the scope (via SpanScope.within(Supplier)), and ends the span when the returned stream terminates: on normal completion, or on an error (recorded on the span first).

Method parameters in org.axonframework.messaging.tracing with type arguments of type MessageStream

Modifier and Type	Method	Description
default <M extends Message> MessageStream<M>	Span.branchStream(@Nullable ProcessingContext context, Function<@Nullable ProcessingContext,MessageStream<M>> operation)	Runs the given MessageStream-producing operation as a branch-scoped span: starts this span, hands the operation a context branch carrying this span's scope (via SpanScope.addToContext(ProcessingContext, SpanScope)) so the operation's own children -- including those created in asynchronous continuations -- parent under this span, executes the operation's synchronous frame within the scope (via SpanScope.within(Supplier)), and ends the span when the returned stream terminates: on normal completion, or on an error (recorded on the span first).

Uses of MessageStream in org.axonframework.test.fixture

Methods in org.axonframework.test.fixture that return MessageStream

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