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

Packages that use MessageStream.Empty

Package	Description
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.eventhandling	Package for event handling components in Axon Framework.
org.axonframework.messaging.eventhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.deadletter	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.segmenting	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.replay	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.tracing	Part of the Axon Messaging module.

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

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

Modifier and Type	Method	Description
default <T extends Message> MessageStream.Empty<T>	MessageStream.Empty.cast()
static <M extends Message> MessageStream.Empty<M>	MessageStream.empty()	Create a stream that carries no MessageStream.Entry and is considered to be successfully completed.
static <M extends Message> MessageStream.Empty<M>	MessageStream.failed(Throwable failure)	Create a stream that completed with given failure.
default MessageStream.Empty<M>	MessageStream.Empty.first()
default MessageStream.Empty<M>	MessageStream.ignoreEntries()	Returns a stream that consumes all messages from this stream, but ignores the results and completes when this stream completes.
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default <RM extends Message> MessageStream.Empty<RM>	MessageStream.Empty.mapMessage(Function<M,RM> mapper)
default MessageStream.Empty<M>	MessageStream.Empty.onComplete(Runnable completeHandler)
default MessageStream.Empty<M>	MessageStream.Empty.onNext(Consumer<MessageStream.Entry<M>> onNext)

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

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	EventHandler.handle(EventMessage event, ProcessingContext context)	Handles the given event within the given context.
default MessageStream.Empty<Message>	EventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.annotation

Methods in org.axonframework.messaging.eventhandling.annotation that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.deadletter

Methods in org.axonframework.messaging.eventhandling.deadletter that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DeadLetteringEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	DeadLetteringEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)

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

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	InterceptingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.processing

Methods in org.axonframework.messaging.eventhandling.processing that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ProcessorEventHandlingComponents.handle(List<? extends EventMessage> events, ProcessingContext context)	Processes a batch of events in the processing context.

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.processing.streaming.segmenting

Methods in org.axonframework.messaging.eventhandling.processing.streaming.segmenting that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(ReplayStatusChanged statusChange, ProcessingContext context)
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	SequencingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.replay

Methods in org.axonframework.messaging.eventhandling.replay that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	ReplayBlockingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)	Handles the given event unless a replay is in progress.
MessageStream.Empty<Message>	ReplayStatusChangedHandler.handle(ReplayStatusChanged statusChange, ProcessingContext context)	Handles the given ReplayStatusChanged message, allowing for tasks to be performed when the replay starts and ends.
MessageStream.Empty<Message>	ResetHandler.handle(ResetContext resetContext, ProcessingContext context)	Handles the given ResetContext message, performing any necessary reset operations.

Uses of MessageStream.Empty in org.axonframework.messaging.eventhandling.tracing

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

Modifier and Type	Method	Description
MessageStream.Empty<Message>	TracingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)