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

Packages that use MessageStream

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

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

Classes in org.axonframework.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 org.axonframework.axonserver.connector.event that return MessageStream

Modifier and Type	Method	Description
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.source(SourcingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.source(SourcingCondition condition)
MessageStream<EventMessage>	AggregateBasedAxonServerEventStorageEngine.stream(StreamingCondition condition)
MessageStream<EventMessage>	AxonServerEventStorageEngine.stream(StreamingCondition condition)

Uses of MessageStream in org.axonframework.axonserver.connector.query

Classes in org.axonframework.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 org.axonframework.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 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)
MessageStream<EventMessage>	EventStorageEngine.source(SourcingCondition condition)	Creates a finite MessageStream of events matching the given condition.
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>	EventStorageEngine.stream(StreamingCondition condition)	Creates an infinite MessageStream of events matching the given 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)
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)
MessageStream<EventMessage>	AggregateBasedJpaEventStorageEngine.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 implementation of MessageStream that provides basic state management for completion, errors, and callbacks.
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	MergedMessageStream<M extends Message>	A MessageStream implementation that merges two underlying message streams into a single stream.
class	QueueMessageStream<M extends Message>	MessageStream implementation that uses a Queue to make elements available to a consumer.

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(MessageStream<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<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.
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<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<M> iterable, Function<M,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<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<M> stream, Function<M,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<T> stream, Function<T,M> messageSupplier, Function<T,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<?>	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 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<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
static <M extends Message> CompletableFuture<MessageStream.Entry<M>>	MessageStreamUtils.asCompletableFuture(MessageStream<M> source)	Returns a CompletableFuture that completes with the first entry from the given source.
default MessageStream<M>	MessageStream.concatWith(MessageStream<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<M> other)
static <M extends Message> reactor.core.publisher.Flux<MessageStream.Entry<M>>	FluxUtils.of(MessageStream<M> source)	Creates a Flux containing the entries provided by the given source.
static <M extends Message, R> CompletableFuture<R>	MessageStreamUtils.reduce(MessageStream<M> source, R identity, BiFunction<R,MessageStream.Entry<M>,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
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 MessageStream<M>	MessageStream.onErrorContinue(Function<Throwable,MessageStream<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.

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

Methods in org.axonframework.messaging.core.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<?>	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)
static MessageStream<?>	MessageStreamResolverUtils.resolveToStream(@Nullable Object result, MessageTypeResolver typeResolver)	Resolves the given result into a MessageStream, 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
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.
<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
default 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)

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>	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 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>	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.distributed

Methods in org.axonframework.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 org.axonframework.messaging.queryhandling.interception

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

Modifier and Type	Method	Description
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.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)