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

Packages that use MessageStream.Empty

Package	Description
io.axoniq.framework.messaging.eventhandling.deadletter	Part of the Axon Messaging module.
io.axoniq.framework.workflow.history.inmemory	In-memory WorkflowHistoryRepository implementation and the event handler that projects workflow events into it.
io.axoniq.framework.workflow.runtime.execution	Internal implementation of the workflow execution engine: the WorkflowEngine, its scheduling, state and storage, checkpointing/replay support, cancellation coordination, and the delegates implementing individual step primitives.
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.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	Tracing decorators for event handling components.
org.axonframework.modelling.saga	Association values, the means by which an event is correlated to the saga instances that should handle it.

Uses of MessageStream.Empty in io.axoniq.framework.messaging.eventhandling.deadletter

Methods in io.axoniq.framework.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 io.axoniq.framework.workflow.history.inmemory

Methods in io.axoniq.framework.workflow.history.inmemory that return MessageStream.Empty

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

Uses of MessageStream.Empty in io.axoniq.framework.workflow.runtime.execution

Methods in io.axoniq.framework.workflow.runtime.execution that return MessageStream.Empty

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

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)
default MessageStream.Empty<Message>	EventHandlingComponent.handle(ResetContext resetContext, ProcessingContext context)
MessageStream.Empty<Message>	EventHandlingExceptionHandler.handle(EventMessage event, ProcessingContext context, Throwable error)	Called when an event handler throws an exception.
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.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<MessageStream.Entry<? extends EventMessage>> entries, ProcessingContext context)	Processes a batch of events in the given 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)

Uses of MessageStream.Empty in org.axonframework.modelling.saga

Methods in org.axonframework.modelling.saga that return MessageStream.Empty

Modifier and Type	Method	Description
MessageStream.Empty<Message>	AbstractSagaManager.handle(EventMessage rawEvent, ProcessingContext context)	Handles the given event within the given context.
MessageStream.Empty<Message>	AbstractSagaManager.handle(ResetContext resetContext, ProcessingContext context)	Handles the given ResetContext message, performing any necessary reset operations.
MessageStream.Empty<Message>	AnnotatedSaga.handle(EventMessage event, ProcessingContext context)
default MessageStream.Empty<Message>	Saga.handle(ResetContext resetContext, ProcessingContext context)