Uses of Interface
org.axonframework.messaging.core.unitofwork.ProcessingContext

Packages that use ProcessingContext

Package	Description
org.axonframework.axonserver.connector.command
org.axonframework.axonserver.connector.event
org.axonframework.axonserver.connector.query
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventsourcing.annotation
org.axonframework.eventsourcing.annotation.reflection
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
org.axonframework.eventsourcing.eventstore.jdbc
org.axonframework.eventsourcing.eventstore.jpa	JPA Implementation of the EventStore.
org.axonframework.extension.spring.authorization
org.axonframework.extension.spring.messaging	Utility classes used to connect Axon Event publishing mechanisms to a Spring Messaging Channel.
org.axonframework.messaging.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.messaging.commandhandling.annotation
org.axonframework.messaging.commandhandling.distributed
org.axonframework.messaging.commandhandling.gateway
org.axonframework.messaging.commandhandling.interception
org.axonframework.messaging.commandhandling.retry
org.axonframework.messaging.commandhandling.tracing
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.messaging.core.annotation
org.axonframework.messaging.core.interception
org.axonframework.messaging.core.interception.annotation
org.axonframework.messaging.core.retry
org.axonframework.messaging.core.unitofwork
org.axonframework.messaging.core.unitofwork.annotation
org.axonframework.messaging.core.unitofwork.transaction
org.axonframework.messaging.eventhandling	Classes related to event handling and dispatching, such as invalid reference Event Listeners and the Event Bus.
org.axonframework.messaging.eventhandling.annotation
org.axonframework.messaging.eventhandling.gateway
org.axonframework.messaging.eventhandling.interception
org.axonframework.messaging.eventhandling.processing
org.axonframework.messaging.eventhandling.processing.streaming.pooled
org.axonframework.messaging.eventhandling.processing.streaming.segmenting
org.axonframework.messaging.eventhandling.processing.streaming.token.store
org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory
org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc
org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa
org.axonframework.messaging.eventhandling.processing.subscribing
org.axonframework.messaging.eventhandling.sequencing
org.axonframework.messaging.eventhandling.tracing
org.axonframework.messaging.eventstreaming
org.axonframework.messaging.monitoring.interception
org.axonframework.messaging.queryhandling
org.axonframework.messaging.queryhandling.annotation
org.axonframework.messaging.queryhandling.distributed
org.axonframework.messaging.queryhandling.gateway
org.axonframework.messaging.queryhandling.interception
org.axonframework.modelling
org.axonframework.modelling.annotation
org.axonframework.modelling.entity
org.axonframework.modelling.entity.annotation
org.axonframework.modelling.entity.child
org.axonframework.modelling.repository
org.axonframework.test.fixture
org.axonframework.test.util	A collection of classes which may prove useful when testing Axon-based classes.

Uses of ProcessingContext in org.axonframework.axonserver.connector.command

Methods in org.axonframework.axonserver.connector.command with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	AxonServerCommandBusConnector.dispatch(CommandMessage command, ProcessingContext processingContext)

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

Methods in org.axonframework.axonserver.connector.event with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<EventStorageEngine.AppendTransaction<?>>	AggregateBasedAxonServerEventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext context, List<TaggedEventMessage<?>> events)
CompletableFuture<EventStorageEngine.AppendTransaction<?>>	AxonServerEventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext context, List<TaggedEventMessage<?>> events)

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

Methods in org.axonframework.axonserver.connector.query with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing with parameters of type ProcessingContext

Modifier and Type	Method	Description
ManagedEntity<ID,E>	EventSourcingRepository.attach(ManagedEntity<ID,E> entity, ProcessingContext processingContext)
E	EventSourcedEntityFactory.create(ID id, EventMessage firstEventMessage, ProcessingContext context)	Creates an entity of type E with the given identifier.
CompletableFuture<ManagedEntity<ID,E>>	EventSourcingRepository.load(ID identifier, ProcessingContext context)
CompletableFuture<ManagedEntity<ID,E>>	EventSourcingRepository.loadOrCreate(ID identifier, ProcessingContext context)
ManagedEntity<ID,E>	EventSourcingRepository.persist(ID identifier, E entity, ProcessingContext processingContext)
EventCriteria	CriteriaResolver.resolve(I identifier, ProcessingContext context)	Resolves the given identifier to an EventCriteria.

Uses of ProcessingContext in org.axonframework.eventsourcing.annotation

Methods in org.axonframework.eventsourcing.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
EventCriteria	AnnotationBasedEventCriteriaResolver.resolve(Object id, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.eventsourcing.annotation.reflection

Methods in org.axonframework.eventsourcing.annotation.reflection with parameters of type ProcessingContext

Modifier and Type	Method	Description
E	AnnotationBasedEventSourcedEntityFactory.create(ID id, EventMessage firstEventMessage, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<EventStorageEngine.AppendTransaction<?>>	EventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext context, List<TaggedEventMessage<?>> events)	Appends a List of events to the underlying storage solution.
default CompletableFuture<EventStorageEngine.AppendTransaction<?>>	EventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext context, TaggedEventMessage<?>... events)	Append one or more events to the underlying storage solution.
CompletableFuture<TrackingToken>	InterceptingEventStore.firstToken(ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.firstToken(ProcessingContext context)
CompletableFuture<TrackingToken>	InterceptingEventStore.latestToken(ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.latestToken(ProcessingContext context)
MessageStream<EventMessage>	InterceptingEventStore.open(StreamingCondition condition, ProcessingContext context)
MessageStream<EventMessage>	StorageEngineBackedEventStore.open(StreamingCondition condition, ProcessingContext context)
CompletableFuture<Void>	InterceptingEventStore.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<Void>	StorageEngineBackedEventStore.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<TrackingToken>	InterceptingEventStore.tokenAt(Instant at, ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.tokenAt(Instant at, ProcessingContext context)
EventStoreTransaction	EventStore.transaction(ProcessingContext processingContext)	Retrieves the transaction for appending events for the given processingContext.
EventStoreTransaction	InterceptingEventStore.transaction(ProcessingContext processingContext)
EventStoreTransaction	StorageEngineBackedEventStore.transaction(ProcessingContext processingContext)

Method parameters in org.axonframework.eventsourcing.eventstore with type arguments of type ProcessingContext

Modifier and Type	Method	Description
Registration	InterceptingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	StorageEngineBackedEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type ProcessingContext

Modifier	Constructor	Description
	DefaultEventStoreTransaction(EventStorageEngine eventStorageEngine, ProcessingContext processingContext, Function<EventMessage,TaggedEventMessage<?>> eventTagger)	Constructs a DefaultEventStoreTransaction using the given eventStorageEngine to append events originating from the given context.

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

Methods in org.axonframework.eventsourcing.eventstore.inmemory with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<EventStorageEngine.AppendTransaction<?>>	InMemoryEventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext processingContext, List<TaggedEventMessage<?>> events)

Uses of ProcessingContext in org.axonframework.eventsourcing.eventstore.jdbc

Methods in org.axonframework.eventsourcing.eventstore.jdbc with parameters of type ProcessingContext

Modifier and Type	Method	Description
TransactionalExecutor<Connection>	JdbcTransactionalExecutorProvider.getTransactionalExecutor(ProcessingContext processingContext)

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

Methods in org.axonframework.eventsourcing.eventstore.jpa with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<EventStorageEngine.AppendTransaction<?>>	AggregateBasedJpaEventStorageEngine.appendEvents(AppendCondition condition, ProcessingContext processingContext, List<TaggedEventMessage<?>> events)
TransactionalExecutor<jakarta.persistence.EntityManager>	JpaTransactionalExecutorProvider.getTransactionalExecutor(ProcessingContext processingContext)

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

Methods in org.axonframework.extension.spring.authorization with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.extension.spring.messaging

Methods in org.axonframework.extension.spring.messaging with parameters of type ProcessingContext

Modifier and Type	Method	Description
protected void	OutboundEventMessageChannelAdapter.handle(List<? extends EventMessage> events, ProcessingContext context)	If allows by the filter, wraps the given event in a GenericMessage ands sends it to the configured MessageChannel.

Method parameters in org.axonframework.extension.spring.messaging with type arguments of type ProcessingContext

Modifier and Type	Method	Description
Registration	InboundEventMessageChannelAdapter.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Constructor parameters in org.axonframework.extension.spring.messaging with type arguments of type ProcessingContext

Modifier	Constructor	Description
	InboundEventMessageChannelAdapter(List<BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>>> processors, EventMessageConverter eventMessageConverter)	Initialize the adapter to publish all incoming events to the subscribed processors.

Uses of ProcessingContext in org.axonframework.messaging.commandhandling

Methods in org.axonframework.messaging.commandhandling with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	CommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)	Dispatch the given command to the command handler subscribed to the given command's name.
CompletableFuture<CommandResultMessage>	SimpleCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)
MessageStream.Single<CommandResultMessage>	CommandHandler.handle(CommandMessage command, ProcessingContext context)	Handles the given command within the given context.
MessageStream.Single<CommandResultMessage>	SimpleCommandHandlingComponent.handle(CommandMessage command, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.commandhandling.annotation

Methods in org.axonframework.messaging.commandhandling.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	AnnotatedCommandHandlingComponent.handle(CommandMessage command, ProcessingContext processingContext)

Uses of ProcessingContext in org.axonframework.messaging.commandhandling.distributed

Methods in org.axonframework.messaging.commandhandling.distributed with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	CommandBusConnector.dispatch(CommandMessage command, ProcessingContext processingContext)	Dispatches the given command to the appropriate command bus, which may be local or remote.
CompletableFuture<CommandResultMessage>	DelegatingCommandBusConnector.dispatch(CommandMessage command, ProcessingContext processingContext)
CompletableFuture<CommandResultMessage>	DistributedCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)
CompletableFuture<CommandResultMessage>	PayloadConvertingCommandBusConnector.dispatch(CommandMessage command, ProcessingContext processingContext)

Uses of ProcessingContext in org.axonframework.messaging.commandhandling.gateway

Methods in org.axonframework.messaging.commandhandling.gateway with parameters of type ProcessingContext

Modifier and Type	Method	Description
static CommandDispatcher	CommandDispatcher.forContext(ProcessingContext context)	Creates a dispatcher for the given ProcessingContext.
default <R> CompletableFuture<R>	CommandGateway.send(Object command, Class<R> resultType, ProcessingContext context)	Sends the given command and returns a CompletableFuture immediately, without waiting for the command to execute.
CommandResult	CommandGateway.send(Object command, Metadata metadata, ProcessingContext context)	Sends the given command with the given metadata in the provided context (if available) and returns a CommandResult immediately, without waiting for the command to execute.
default CommandResult	CommandGateway.send(Object command, ProcessingContext context)	Sends the given command in the provided context (if available) and returns a CommandResult immediately, without waiting for the command to execute.
CommandResult	ConvertingCommandGateway.send(Object command, Metadata metadata, ProcessingContext context)
CommandResult	DefaultCommandGateway.send(Object command, Metadata metadata, ProcessingContext context)
default <R> R	CommandGateway.sendAndWait(Object command, Class<R> resultType, ProcessingContext context)	Send the given command and waits for the result converted to the resultType.
default Object	CommandGateway.sendAndWait(Object command, ProcessingContext context)	Send the given command and waits for completion.

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

Methods in org.axonframework.messaging.commandhandling.interception with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	InterceptingCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)
MessageStream<?>	CommandMessageHandlerInterceptorChain.proceed(CommandMessage command, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.commandhandling.retry

Methods in org.axonframework.messaging.commandhandling.retry with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	RetryingCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)

Uses of ProcessingContext in org.axonframework.messaging.commandhandling.tracing

Methods in org.axonframework.messaging.commandhandling.tracing with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	TracingCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)

Uses of ProcessingContext in org.axonframework.messaging.core

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

Modifier and Type	Method	Description
static ProcessingContext	Message.addToContext(ProcessingContext context, Message message)	Adds the given message to the given context under the Message.RESOURCE_KEY.

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

Modifier and Type	Method	Description
static ProcessingContext	Message.addToContext(ProcessingContext context, Message message)	Adds the given message to the given context under the Message.RESOURCE_KEY.
static Message	Message.fromContext(ProcessingContext context)	Retrieves the Message from the given context using the Message.RESOURCE_KEY.
MessageStream<?>	MessageDispatchInterceptor.interceptOnDispatch(M message, 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.
MessageStream<?>	DefaultMessageDispatchInterceptorChain.proceed(M message, ProcessingContext context)
MessageStream<?>	MessageDispatchInterceptorChain.proceed(M message, 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.

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

Modifier and Type	Method	Description
Registration	SubscribableEventSource.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)	Subscribe the given eventsBatchConsumer to this event source.

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

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 ProcessingContext in org.axonframework.messaging.core.annotation

Methods in org.axonframework.messaging.core.annotation with parameters of type ProcessingContext

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.
boolean	MessageHandlingMember.canHandle(Message message, ProcessingContext context)	Checks if this handler is capable of handling the given message.
boolean	MethodInvokingMessageHandlingMember.canHandle(Message message, ProcessingContext context)
boolean	WrappedMessageHandlingMember.canHandle(Message message, ProcessingContext context)
static <M extends Message> MessageHandlerInterceptorChain<M>	InterceptorChainParameterResolverFactory.currentInterceptorChain(ProcessingContext processingContext)
MessageStream<?>	ChainedMessageHandlerInterceptorMember.handle(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
MessageStream<?>	MessageHandlingMember.handle(Message message, ProcessingContext context, 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, T target)
MessageStream<?>	WrappedMessageHandlingMember.handle(Message message, ProcessingContext context, T target)
Object	ChainedMessageHandlerInterceptorMember.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)
Object	MessageHandlingMember.handleSync(Message message, ProcessingContext context, T target)	Deprecated, for removal: This API element is subject to removal in a future version. In favor of MessageHandlingMember.handle(Message, ProcessingContext, Object).
Object	MethodInvokingMessageHandlingMember.handleSync(Message message, ProcessingContext context, T target)
Object	WrappedMessageHandlingMember.handleSync(Message message, ProcessingContext context, T target)
boolean	FixedValueParameterResolver.matches(ProcessingContext context)
boolean	InterceptorChainParameterResolverFactory.matches(ProcessingContext context)
boolean	ParameterResolver.matches(ProcessingContext context)	Indicates whether this resolver is capable of providing a value for the given context.
boolean	PayloadParameterResolver.matches(ProcessingContext context)
protected boolean	MethodInvokingMessageHandlingMember.parametersMatch(Message message, ProcessingContext processingContext)	Checks if the parameter resolvers of this member are compatible with the given message.
CompletableFuture<T>	FixedValueParameterResolver.resolveParameterValue(ProcessingContext context)
CompletableFuture<MessageHandlerInterceptorChain<?>>	InterceptorChainParameterResolverFactory.resolveParameterValue(ProcessingContext context)
CompletableFuture<T>	ParameterResolver.resolveParameterValue(ProcessingContext context)	Asynchronously resolves the parameter value from the context.
CompletableFuture<Object>	PayloadParameterResolver.resolveParameterValue(ProcessingContext context)

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

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 ProcessingContext in org.axonframework.messaging.core.interception

Methods in org.axonframework.messaging.core.interception with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream<?>	BeanValidationInterceptor.interceptOnDispatch(M message, ProcessingContext context, MessageDispatchInterceptorChain<M> dispatchInterceptorChain)
MessageStream<?>	CorrelationDataInterceptor.interceptOnDispatch(M message, ProcessingContext context, MessageDispatchInterceptorChain<M> chain)
MessageStream<?>	LoggingInterceptor.interceptOnDispatch(M message, 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 ProcessingContext in org.axonframework.messaging.core.interception.annotation

Methods in org.axonframework.messaging.core.interception.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
static <R> R	ResultParameterResolverFactory.callWithResult(Object result, ProcessingContext processingContext, Function<ProcessingContext,R> action)
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)
Object	MessageHandlerInterceptorMemberChain.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)	Deprecated, for removal: This API element is subject to removal in a future version.
Object	NoMoreInterceptors.handleSync(Message message, ProcessingContext context, T target, MessageHandlingMember<? super T> handler)	Deprecated.
static <T> T	ResultParameterResolverFactory.ignoringResultParameters(ProcessingContext processingContext, Function<ProcessingContext,T> action)	Performs the given action ignoring any parameters expecting a result type.

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

Modifier and Type	Method	Description
static <R> R	ResultParameterResolverFactory.callWithResult(Object result, ProcessingContext processingContext, Function<ProcessingContext,R> action)
static <T> T	ResultParameterResolverFactory.ignoringResultParameters(ProcessingContext processingContext, Function<ProcessingContext,T> action)	Performs the given action ignoring any parameters expecting a result type.

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

Methods in org.axonframework.messaging.core.retry with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.messaging.core.unitofwork

Classes in org.axonframework.messaging.core.unitofwork that implement ProcessingContext

Modifier and Type	Class	Description
class	LegacyMessageSupportingContext	Deprecated. Only in use for legacy "sync" components.
class	ResourceOverridingProcessingContext<R>	A ProcessingContext implementation overriding a single resource from the wrapping ProcessingContext.

Methods in org.axonframework.messaging.core.unitofwork that return ProcessingContext

Modifier and Type	Method	Description
default <T> ProcessingContext	ProcessingContext.withResource(Context.ResourceKey<T> key, T resource)	Constructs a new ProcessingContext, branching off from this ProcessingContext.

Methods in org.axonframework.messaging.core.unitofwork with parameters of type ProcessingContext

Modifier and Type	Method	Description
void	ProcessingLifecycle.ErrorHandler.handle(ProcessingContext processingContext, ProcessingLifecycle.Phase phase, Throwable error)	Invoked when an error is detected in a ProcessingLifecycle and it has been aborted.

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

Modifier and Type	Method	Description
default ProcessingLifecycle	ProcessingLifecycle.doFinally(Consumer<ProcessingContext> action)	Registers the provided action to be executed on error of and when completing this ProcessingLifecycle.
ProcessingLifecycle	ResourceOverridingProcessingContext.doFinally(Consumer<ProcessingContext> action)
<R> CompletableFuture<R>	UnitOfWork.executeWithResult(Function<ProcessingContext,CompletableFuture<R>> action)	Registers the given action for the invocation Phase and executes this Unit of Work right away.
ProcessingLifecycle	LegacyMessageSupportingContext.on(ProcessingLifecycle.Phase phase, Function<ProcessingContext,CompletableFuture<?>> action)	Deprecated.
ProcessingLifecycle	ProcessingLifecycle.on(ProcessingLifecycle.Phase phase, Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the given phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.on(ProcessingLifecycle.Phase phase, Function<ProcessingContext,CompletableFuture<?>> action)
UnitOfWork	UnitOfWork.on(ProcessingLifecycle.Phase phase, Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onAfterCommit(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the after commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onAfterCommit(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onCommit(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onCommit(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onInvocation(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onInvocation(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onPostInvocation(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the post invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onPostInvocation(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onPreInvocation(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the pre-invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onPreInvocation(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.onPrepareCommit(Function<ProcessingContext,CompletableFuture<?>> action)	Registers the provided action to be executed in the prepare commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.onPrepareCommit(Function<ProcessingContext,CompletableFuture<?>> action)
default ProcessingLifecycle	ProcessingLifecycle.runOn(ProcessingLifecycle.Phase phase, Consumer<ProcessingContext> action)	Registers the provided action to be executed in the given phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOn(ProcessingLifecycle.Phase phase, Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnAfterCommit(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the after commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnAfterCommit(Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnCommit(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnCommit(Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnInvocation(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnInvocation(Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnPostInvocation(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the post invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnPostInvocation(Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnPreInvocation(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the pre-invocation phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnPreInvocation(Consumer<ProcessingContext> action)
default ProcessingLifecycle	ProcessingLifecycle.runOnPrepareCommit(Consumer<ProcessingContext> action)	Registers the provided action to be executed in the prepare commit phase.
ProcessingLifecycle	ResourceOverridingProcessingContext.runOnPrepareCommit(Consumer<ProcessingContext> action)
ProcessingLifecycle	LegacyMessageSupportingContext.whenComplete(Consumer<ProcessingContext> action)	Deprecated.
ProcessingLifecycle	ProcessingLifecycle.whenComplete(Consumer<ProcessingContext> action)	Registers the provided action to be executed when this ProcessingLifecycle completes all registered actions.
ProcessingLifecycle	ResourceOverridingProcessingContext.whenComplete(Consumer<ProcessingContext> action)
ProcessingLifecycle	UnitOfWork.whenComplete(Consumer<ProcessingContext> action)

Constructors in org.axonframework.messaging.core.unitofwork with parameters of type ProcessingContext

Modifier	Constructor	Description
	ResourceOverridingProcessingContext(ProcessingContext delegate, Context.ResourceKey<R> key, R resource)	Constructs a resource-overriding ProcessingContext using the provided parameters.

Uses of ProcessingContext in org.axonframework.messaging.core.unitofwork.annotation

Methods in org.axonframework.messaging.core.unitofwork.annotation that return types with arguments of type ProcessingContext

Modifier and Type	Method	Description
ParameterResolver<ProcessingContext>	ProcessingContextParameterResolverFactory.createInstance(Executable executable, Parameter[] parameters, int parameterIndex)

Uses of ProcessingContext in org.axonframework.messaging.core.unitofwork.transaction

Methods in org.axonframework.messaging.core.unitofwork.transaction with parameters of type ProcessingContext

Modifier and Type	Method	Description
TransactionalExecutor<T>	TransactionalExecutorProvider.getTransactionalExecutor(ProcessingContext processingContext)	Provides a TransactionalExecutor, using the optional processing context.

Uses of ProcessingContext in org.axonframework.messaging.eventhandling

Methods in org.axonframework.messaging.eventhandling with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream.Empty<Message>	DelegatingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	EventHandler.handle(EventMessage event, ProcessingContext context)	Handles the given event within the given context.
MessageStream.Empty<Message>	SimpleEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
CompletableFuture<Void>	DelegatingEventBus.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<Void>	EventSink.publish(ProcessingContext context, List<EventMessage> events)	Publishes the given events within the given context, when present.
default CompletableFuture<Void>	EventSink.publish(ProcessingContext context, EventMessage... events)	Publishes the given events within the given context, when present.
CompletableFuture<Void>	InterceptingEventBus.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<Void>	InterceptingEventSink.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<Void>	SimpleEventBus.publish(ProcessingContext context, List<EventMessage> events)
Object	DelegatingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)
Object	EventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.
Object	SimpleEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.

Method parameters in org.axonframework.messaging.eventhandling with type arguments of type ProcessingContext

Modifier and Type	Method	Description
Registration	DelegatingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	InterceptingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	SimpleEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.annotation

Methods in org.axonframework.messaging.eventhandling.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream.Empty<Message>	AnnotatedEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
boolean	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.matches(ProcessingContext context)
CompletableFuture<Long>	SequenceNumberParameterResolverFactory.SequenceNumberParameterResolver.resolveParameterValue(ProcessingContext context)
Object	AnnotatedEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.gateway

Methods in org.axonframework.messaging.eventhandling.gateway with parameters of type ProcessingContext

Modifier and Type	Method	Description
static EventAppender	EventAppender.forContext(ProcessingContext context)	Creates an appender for the given ProcessingContext.
static EventAppender	EventAppender.forContext(ProcessingContext context, EventSink eventSink, MessageTypeResolver messageTypeResolver)	Creates an appender for the given ProcessingContext and EventSink.
CompletableFuture<Void>	DefaultEventGateway.publish(ProcessingContext context, List<?> events)
default CompletableFuture<Void>	EventGateway.publish(ProcessingContext context, Object... events)	Publishes the given events within the given context.
CompletableFuture<Void>	EventGateway.publish(ProcessingContext context, List<?> events)	Publishes the given events within the given context.

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

Methods in org.axonframework.messaging.eventhandling.interception with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing

Methods in org.axonframework.messaging.eventhandling.processing with parameters of type ProcessingContext

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.
Set<Object>	ProcessorEventHandlingComponents.sequenceIdentifiersFor(EventMessage event, ProcessingContext context)	Retrieves a set of sequence identifiers for the given event message and processing context.

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return types with arguments of type ProcessingContext

Modifier and Type	Method	Description
Supplier<ProcessingContext>	PooledStreamingEventProcessorConfiguration.schedulingProcessingContextProvider()	Returns the Supplier providing the ProcessingContext used to evaluate whether an event can be scheduled for processing by this WorkPackage.

Method parameters in org.axonframework.messaging.eventhandling.processing.streaming.pooled with type arguments of type ProcessingContext

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.schedulingProcessingContextProvider(Supplier<ProcessingContext> schedulingProcessingContextProvider)	Provides a ProcessingContext used to evaluate whether an event can be scheduled for processing by this WorkPackage.

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.segmenting

Methods in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream.Empty<Message>	SequenceOverridingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
MessageStream.Empty<Message>	SequencingEventHandlingComponent.handle(EventMessage event, ProcessingContext context)
boolean	SegmentMatcher.matches(Segment segment, EventMessage event, ProcessingContext context)	Checks whether the given segment matches the given event, based on the configured sequencing policy.
Object	SegmentMatcher.sequenceIdentifier(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event, as defined by the configured sequencing policy.
Object	SequenceCachingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)
Object	SequenceOverridingEventHandlingComponent.sequenceIdentifierFor(EventMessage event, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.token.store

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	TokenStore.deleteToken(String processorName, int segmentId, ProcessingContext context)	Deletes the token associated with the specified processorName and segmentId.
default CompletableFuture<Void>	TokenStore.extendClaim(String processorName, int segmentId, ProcessingContext context)	Extends the claim on the current token held by this node for the given processorName and segment.
CompletableFuture<List<Segment>>	TokenStore.fetchAvailableSegments(String processorName, ProcessingContext context)	Returns a CompletableFuture supplying a List of known available Segments for a given processorName.
CompletableFuture<Segment>	TokenStore.fetchSegment(String processorName, int segmentId, ProcessingContext context)	Returns a CompletableFuture that supplies the specified Segment, or null if there was no such segment.
CompletableFuture<List<Segment>>	TokenStore.fetchSegments(String processorName, ProcessingContext context)	Returns a CompletableFuture that supplies a list of known segments for a given processorName on completion.
CompletableFuture<TrackingToken>	TokenStore.fetchToken(String processorName, int segmentId, ProcessingContext context)	Fetches the last stored token for the given processorName and segmentId.
default CompletableFuture<TrackingToken>	TokenStore.fetchToken(String processorName, Segment segment, ProcessingContext context)	Fetches the last stored token for the given processorName and segment.
CompletableFuture<Void>	TokenStore.initializeSegment(TrackingToken token, String processorName, Segment segment, ProcessingContext context)	Initializes a segment with given segment for the processor with given processorName to contain the given token.
CompletableFuture<List<Segment>>	TokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken, ProcessingContext context)	Initializes a given number of segments for the given processorName to track its tokens.
CompletableFuture<Void>	TokenStore.releaseClaim(String processorName, int segmentId, ProcessingContext context)	Release a claim of the token for given processorName and segment.
CompletableFuture<String>	TokenStore.retrieveStorageIdentifier(ProcessingContext context)	Retrieves the storage identifier associated with this store.
CompletableFuture<Void>	TokenStore.storeToken(TrackingToken token, String processorName, int segmentId, ProcessingContext context)	Stores the given token in the store.

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryTokenStore.deleteToken(String processorName, int segment, ProcessingContext context)
CompletableFuture<List<Segment>>	InMemoryTokenStore.fetchAvailableSegments(String processorName, ProcessingContext context)
CompletableFuture<Segment>	InMemoryTokenStore.fetchSegment(String processorName, int segmentId, ProcessingContext context)
CompletableFuture<List<Segment>>	InMemoryTokenStore.fetchSegments(String processorName, ProcessingContext context)
CompletableFuture<TrackingToken>	InMemoryTokenStore.fetchToken(String processorName, int segmentId, ProcessingContext context)
CompletableFuture<Void>	InMemoryTokenStore.initializeSegment(TrackingToken token, String processorName, Segment segment, ProcessingContext context)
CompletableFuture<List<Segment>>	InMemoryTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken, ProcessingContext context)
CompletableFuture<Void>	InMemoryTokenStore.releaseClaim(String processorName, int segment, ProcessingContext context)
CompletableFuture<String>	InMemoryTokenStore.retrieveStorageIdentifier(ProcessingContext context)
CompletableFuture<Void>	InMemoryTokenStore.storeToken(TrackingToken token, String processorName, int segmentId, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	JdbcTokenStore.deleteToken(String processorName, int segment, ProcessingContext context)
CompletableFuture<List<Segment>>	JdbcTokenStore.fetchAvailableSegments(String processorName, ProcessingContext context)
CompletableFuture<Segment>	JdbcTokenStore.fetchSegment(String processorName, int segmentId, ProcessingContext context)
CompletableFuture<List<Segment>>	JdbcTokenStore.fetchSegments(String processorName, ProcessingContext context)
CompletableFuture<TrackingToken>	JdbcTokenStore.fetchToken(String processorName, int segment, ProcessingContext context)
CompletableFuture<TrackingToken>	JdbcTokenStore.fetchToken(String processorName, Segment segment, ProcessingContext context)
CompletableFuture<Void>	JdbcTokenStore.initializeSegment(TrackingToken token, String processorName, Segment segment, ProcessingContext context)
CompletableFuture<List<Segment>>	JdbcTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken, ProcessingContext context)
CompletableFuture<Void>	JdbcTokenStore.releaseClaim(String processorName, int segment, ProcessingContext context)
CompletableFuture<String>	JdbcTokenStore.retrieveStorageIdentifier(ProcessingContext context)
CompletableFuture<Void>	JdbcTokenStore.storeToken(TrackingToken token, String processorName, int segment, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	JpaTokenStore.deleteToken(String processorName, int segment, ProcessingContext context)
CompletableFuture<Void>	JpaTokenStore.extendClaim(String processorName, int segment, ProcessingContext context)
CompletableFuture<List<Segment>>	JpaTokenStore.fetchAvailableSegments(String processorName, ProcessingContext context)
CompletableFuture<Segment>	JpaTokenStore.fetchSegment(String processorName, int segmentId, ProcessingContext context)
CompletableFuture<List<Segment>>	JpaTokenStore.fetchSegments(String processorName, ProcessingContext context)
CompletableFuture<TrackingToken>	JpaTokenStore.fetchToken(String processorName, int segment, ProcessingContext context)
CompletableFuture<TrackingToken>	JpaTokenStore.fetchToken(String processorName, Segment segment, ProcessingContext context)
CompletableFuture<Void>	JpaTokenStore.initializeSegment(TrackingToken token, String processorName, Segment segment, ProcessingContext context)
CompletableFuture<List<Segment>>	JpaTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken, ProcessingContext context)
CompletableFuture<Void>	JpaTokenStore.releaseClaim(String processorName, int segment, ProcessingContext context)
CompletableFuture<String>	JpaTokenStore.retrieveStorageIdentifier(ProcessingContext context)
CompletableFuture<Void>	JpaTokenStore.storeToken(TrackingToken token, String processorName, int segment, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.processing.subscribing

Methods in org.axonframework.messaging.eventhandling.processing.subscribing with parameters of type ProcessingContext

Modifier and Type	Method	Description
protected void	SubscribingEventProcessor.process(List<EventMessage> eventMessages, ProcessingContext context)	Process the given messages.

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.sequencing

Methods in org.axonframework.messaging.eventhandling.sequencing with parameters of type ProcessingContext

Modifier and Type	Method	Description
Optional<Object>	ExtractionSequencingPolicy.getSequenceIdentifierFor(EventMessage eventMessage, ProcessingContext context)
Optional<Object>	FallbackSequencingPolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)
Optional<Object>	FullConcurrencyPolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)
Optional<Object>	HierarchicalSequencingPolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)
Optional<Object>	MetadataSequencingPolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)
Optional<Object>	SequencingPolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)	Returns the sequence identifier for the given event.
Optional<Object>	SequentialPerAggregatePolicy.getSequenceIdentifierFor(EventMessage event, ProcessingContext context)
Optional<Object>	SequentialPolicy.getSequenceIdentifierFor(EventMessage task, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.messaging.eventhandling.tracing

Methods in org.axonframework.messaging.eventhandling.tracing with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.messaging.eventstreaming

Methods in org.axonframework.messaging.eventstreaming with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	TrackingTokenSource.firstToken(ProcessingContext context)	Creates a TrackingToken representing the first position of the event stream.
CompletableFuture<TrackingToken>	TrackingTokenSource.latestToken(ProcessingContext context)	Creates a TrackingToken representing the latest position, thus pointing at the next event of the event stream.
MessageStream<EventMessage>	StreamableEventSource.open(StreamingCondition condition, ProcessingContext context)	Open an event stream containing all events matching the given condition.
CompletableFuture<TrackingToken>	TrackingTokenSource.tokenAt(Instant at, ProcessingContext context)	Creates a TrackingToken tracking all events after the given at from an event stream.

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

Methods in org.axonframework.messaging.monitoring.interception with parameters of type ProcessingContext

Modifier and Type	Method	Description
MessageStream<?>	MonitoringEventDispatchInterceptor.interceptOnDispatch(EventMessage message, ProcessingContext context, MessageDispatchInterceptorChain<EventMessage> interceptorChain)
MessageStream<?>	MonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, 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 ProcessingContext in org.axonframework.messaging.queryhandling

Methods in org.axonframework.messaging.queryhandling with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	QueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)	Completes subscription queries matching the given filter.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	QueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	QueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)	Emits the outcome of the updateSupplier to subscription queries matching the given queryName and given filter.
CompletableFuture<Void>	SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)
static QueryUpdateEmitter	QueryUpdateEmitter.forContext(ProcessingContext context)	Creates a query update emitter for the given ProcessingContext.
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, 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, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.subscriptionQuery(QueryMessage query, 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, ProcessingContext context, int updateBufferSize)

Constructors in org.axonframework.messaging.queryhandling with parameters of type ProcessingContext

Modifier	Constructor	Description
	SimpleQueryUpdateEmitter(QueryBus queryBus, MessageTypeResolver messageTypeResolver, MessageConverter converter, ProcessingContext context)	Construct a SimpleQueryUpdateEmitter with the given messageTypeResolver, queryBus, and context.

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

Methods in org.axonframework.messaging.queryhandling.annotation with parameters of type ProcessingContext

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

Uses of ProcessingContext in org.axonframework.messaging.queryhandling.distributed

Methods in org.axonframework.messaging.queryhandling.distributed with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	DistributedQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBusConnector.query(QueryMessage query, ProcessingContext context)	Sends the given query to the remote QueryBus.
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	DistributedQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)	Sends the given query to the remote QueryBus.

Uses of ProcessingContext in org.axonframework.messaging.queryhandling.gateway

Methods in org.axonframework.messaging.queryhandling.gateway with parameters of type ProcessingContext

Modifier and Type	Method	Description
<R> CompletableFuture<R>	DefaultQueryGateway.query(Object query, Class<R> responseType, ProcessingContext context)
<R> CompletableFuture<R>	QueryGateway.query(Object query, Class<R> responseType, ProcessingContext context)	Sends given query over the QueryBus, expecting a single response with the given responseType from a single source.
<R> CompletableFuture<List<R>>	DefaultQueryGateway.queryMany(Object query, Class<R> responseType, ProcessingContext context)
<R> CompletableFuture<List<R>>	QueryGateway.queryMany(Object query, Class<R> responseType, ProcessingContext context)	Sends given query over the QueryBus, expecting multiple responses in the form of responseType from a single source.
<R> org.reactivestreams.Publisher<R>	DefaultQueryGateway.streamingQuery(Object query, Class<R> responseType, ProcessingContext context)
<R> org.reactivestreams.Publisher<R>	QueryGateway.streamingQuery(Object query, Class<R> responseType, ProcessingContext context)	Sends given query over the QueryBus, expecting a response as a Publisher of responseType.
<R> org.reactivestreams.Publisher<R>	DefaultQueryGateway.subscriptionQuery(Object query, Class<R> responseType, ProcessingContext context, int updateBufferSize)
<T> org.reactivestreams.Publisher<T>	DefaultQueryGateway.subscriptionQuery(Object query, Class<T> responseType, Function<QueryResponseMessage,T> mapper, ProcessingContext context, int updateBufferSize)
default <R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, ProcessingContext context)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
<R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, ProcessingContext context, int updateBufferSize)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
default <R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, ProcessingContext context)	Sends given query over the QueryBus as a subscription query, combining the initial result and emitted update as a Publisher of the given responseType.
<R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, ProcessingContext context, int updateBufferSize)	Sends given query over the QueryBus as a subscription query, combining the initial result and emitted update as a Publisher of the given responseType.

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

Methods in org.axonframework.messaging.queryhandling.interception with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<Void>	InterceptingQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)
MessageStream<?>	QueryMessageHandlerInterceptorChain.proceed(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

Uses of ProcessingContext in org.axonframework.modelling

Methods in org.axonframework.modelling with parameters of type ProcessingContext

Modifier and Type	Method	Description
E	EntityEvolver.evolve(E entity, EventMessage event, ProcessingContext context)	Evolve the given entity by applying the given event to it.
E	PayloadBasedEntityEvolver.evolve(E entity, EventMessage event, ProcessingContext context)
E	SimpleEntityEvolvingComponent.evolve(E entity, EventMessage event, ProcessingContext context)
default <I, T> CompletableFuture<T>	StateManager.loadEntity(Class<T> type, I id, ProcessingContext context)	Retrieves an entity of the given type and id.
<I, T> CompletableFuture<ManagedEntity<I,T>>	HierarchicalStateManager.loadManagedEntity(Class<T> type, I id, ProcessingContext context)
<I, T> CompletableFuture<ManagedEntity<I,T>>	SimpleStateManager.loadManagedEntity(Class<T> entityType, I id, ProcessingContext context)
<ID, T> CompletableFuture<ManagedEntity<ID,T>>	StateManager.loadManagedEntity(Class<T> type, ID id, ProcessingContext context)	Retrieves a ManagedEntity of the given type and id.
ID	EntityIdResolver.resolve(Message message, ProcessingContext context)	Resolve the id of the entity from the given message and context.
Object	PropertyBasedEntityIdResolver.resolve(Message message, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.modelling.annotation

Methods in org.axonframework.modelling.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
E	AnnotationBasedEntityEvolvingComponent.evolve(E entity, EventMessage event, ProcessingContext context)
T	AnnotationBasedEntityIdResolver.resolve(Message message, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.modelling.entity

Methods in org.axonframework.modelling.entity with parameters of type ProcessingContext

Modifier and Type	Method	Description
E	ConcreteEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)
E	PolymorphicEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityCommandHandler.handle(CommandMessage command, E entity, ProcessingContext context)	Handles the given CommandMessage for the given entity.
MessageStream.Single<CommandResultMessage>	EntityCommandHandlingComponent.handle(CommandMessage command, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	ConcreteEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)	Handles the given CommandMessage as the creation of a new entity.
MessageStream.Single<CommandResultMessage>	PolymorphicEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	ConcreteEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)	Handles the given CommandMessage for the given entity.
MessageStream.Single<CommandResultMessage>	PolymorphicEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.modelling.entity.annotation

Methods in org.axonframework.modelling.entity.annotation with parameters of type ProcessingContext

Modifier and Type	Method	Description
E	AnnotatedEntityMetamodel.evolve(E entity, EventMessage event, ProcessingContext context)
E	RoutingKeyCommandTargetResolver.getTargetChildEntity(List<E> childEntities, CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	AnnotatedEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	AnnotatedEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)
boolean	RoutingKeyEventTargetMatcher.matches(E childEntity, EventMessage message, ProcessingContext processingContext)
ID	AnnotatedEntityIdResolver.resolve(Message message, ProcessingContext context)

Uses of ProcessingContext in org.axonframework.modelling.entity.child

Methods in org.axonframework.modelling.entity.child with parameters of type ProcessingContext

Modifier and Type	Method	Description
boolean	AbstractEntityChildMetamodel.canHandle(CommandMessage message, P parentEntity, ProcessingContext context)
boolean	EntityChildMetamodel.canHandle(CommandMessage message, P parentEntity, ProcessingContext context)	Checks if this child can handle the given CommandMessage for the given parent entity, and a child entity is available to handle it.
P	AbstractEntityChildMetamodel.evolve(P entity, EventMessage event, ProcessingContext context)
E	CommandTargetResolver.getTargetChildEntity(List<E> candidates, CommandMessage message, ProcessingContext context)	Returns the target child entity for the given command message.
MessageStream.Single<CommandResultMessage>	AbstractEntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context)	Handles the given CommandMessage for the given child entity, using the provided parent entity.
boolean	EventTargetMatcher.matches(E targetEntity, EventMessage message, ProcessingContext processingContext)	Tests whether the given entity should be evolved for the given EventMessage.

Uses of ProcessingContext in org.axonframework.modelling.repository

Methods in org.axonframework.modelling.repository with parameters of type ProcessingContext

Modifier and Type	Method	Description
ManagedEntity<ID,E>	AccessSerializingRepository.attach(ManagedEntity<ID,E> entity, ProcessingContext processingContext)
ManagedEntity<ID,E>	InMemoryRepository.attach(ManagedEntity<ID,E> entity, ProcessingContext processingContext)
ManagedEntity<ID,E>	Repository.LifecycleManagement.attach(ManagedEntity<ID,E> entity, ProcessingContext processingContext)	Ensures that the given entity has its lifecycle managed in the given processingContext.
ManagedEntity<ID,E>	SimpleRepository.attach(ManagedEntity<ID,E> entity, ProcessingContext context)
CompletableFuture<ManagedEntity<ID,E>>	AccessSerializingRepository.load(ID identifier, ProcessingContext processingContext)
CompletableFuture<ManagedEntity<ID,E>>	InMemoryRepository.load(ID identifier, ProcessingContext processingContext)
CompletableFuture<ManagedEntity<ID,E>>	Repository.load(ID identifier, ProcessingContext processingContext)	Load the entity with the given unique identifier.
CompletableFuture<ManagedEntity<ID,E>>	SimpleRepository.load(ID id, ProcessingContext context)
CompletableFuture<? extends T>	SimpleRepositoryEntityLoader.load(I id, ProcessingContext context)	Load an entity with given id within the given context.
CompletableFuture<ManagedEntity<ID,E>>	AccessSerializingRepository.loadOrCreate(ID identifier, ProcessingContext processingContext)
CompletableFuture<ManagedEntity<ID,E>>	InMemoryRepository.loadOrCreate(ID identifier, ProcessingContext processingContext)
CompletableFuture<ManagedEntity<ID,E>>	Repository.loadOrCreate(ID identifier, ProcessingContext processingContext)	Loads an entity from the repository.
CompletableFuture<ManagedEntity<ID,E>>	SimpleRepository.loadOrCreate(ID identifier, ProcessingContext processingContext)
ManagedEntity<ID,E>	AccessSerializingRepository.persist(ID identifier, E entity, ProcessingContext processingContext)
ManagedEntity<ID,E>	InMemoryRepository.persist(ID identifier, E entity, ProcessingContext processingContext)
ManagedEntity<ID,E>	Repository.persist(ID identifier, E entity, ProcessingContext processingContext)	Persists the given entity in this repository
ManagedEntity<ID,E>	SimpleRepository.persist(ID id, E entity, ProcessingContext context)
CompletableFuture<Void>	SimpleRepositoryEntityPersister.persist(I id, T entity, ProcessingContext context)	Persist the given entity with given id within the given context.

Uses of ProcessingContext in org.axonframework.test.fixture

Methods in org.axonframework.test.fixture with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	RecordingCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)
CompletableFuture<TrackingToken>	RecordingEventStore.firstToken(ProcessingContext context)
CompletableFuture<TrackingToken>	RecordingEventStore.latestToken(ProcessingContext context)
MessageStream<EventMessage>	RecordingEventStore.open(StreamingCondition condition, ProcessingContext context)
CompletableFuture<Void>	RecordingEventSink.publish(ProcessingContext context, List<EventMessage> events)
CompletableFuture<TrackingToken>	RecordingEventStore.tokenAt(Instant at, ProcessingContext context)
EventStoreTransaction	RecordingEventStore.transaction(@NotNull ProcessingContext processingContext)

Method parameters in org.axonframework.test.fixture with type arguments of type ProcessingContext

Modifier and Type	Method	Description
Registration	RecordingEventBus.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)
Registration	RecordingEventStore.subscribe(BiFunction<List<? extends EventMessage>,ProcessingContext,CompletableFuture<?>> eventsBatchConsumer)

Uses of ProcessingContext in org.axonframework.test.util

Methods in org.axonframework.test.util with parameters of type ProcessingContext

Modifier and Type	Method	Description
CompletableFuture<CommandResultMessage>	RecordingCommandBus.dispatch(CommandMessage command, ProcessingContext processingContext)