Package org.axonframework.messaging.monitoring.interception

Class MonitoringCommandHandlerInterceptor

java.lang.Object

org.axonframework.messaging.monitoring.interception.MonitoringCommandHandlerInterceptor

All Implemented Interfaces:

MessageHandlerInterceptor<CommandMessage>

public class MonitoringCommandHandlerInterceptor
extends Object
implements MessageHandlerInterceptor<CommandMessage>

A MessageHandlerInterceptor for CommandMessage that intercepts the MessageHandlerInterceptorChain to register the MessageMonitor.MonitorCallback functions on the ProcessingContext hooks.

Invoked by the InterceptingCommandBus.

Commands are only monitored when handled.

Since:

5.0.0

Author:

Jan Galinski

Constructor Summary

Constructors

Constructor	Description
MonitoringCommandHandlerInterceptor(MessageMonitor<? super CommandMessage> messageMonitor)	Constructs a MonitoringCommandHandlerInterceptor using the given MessageMonitor.

Method Summary

Modifier and Type	Method	Description
MessageStream<?>	interceptOnHandle(CommandMessage message, ProcessingContext context, MessageHandlerInterceptorChain<CommandMessage> interceptorChain)	Intercepts a given message on handling before reaching the designated MessageHandler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MonitoringCommandHandlerInterceptor

public MonitoringCommandHandlerInterceptor(@Nonnull
 MessageMonitor<? super CommandMessage> messageMonitor)

Constructs a MonitoringCommandHandlerInterceptor using the given MessageMonitor.

Parameters:

messageMonitor - The MessageMonitor instance used for reporting.

Method Details

interceptOnHandle

@Nonnull
public MessageStream<?> interceptOnHandle(@Nonnull
 CommandMessage message,
 @Nonnull
 ProcessingContext context,
 @Nonnull
 MessageHandlerInterceptorChain<CommandMessage> interceptorChain)

Description copied from interface: MessageHandlerInterceptor

Intercepts a given message on handling before reaching the designated MessageHandler.

The interceptor is responsible for the continuation of the handling process by invoking the MessageHandlerInterceptorChain.proceed(Message, ProcessingContext) method on the given interceptorChain.

The given context contains contextual information. Any information gathered by interceptors may be attached to the context.

Interceptors are not allowed to change the type of the message handling result, as the dispatching component expects a result of a specific type.

Specified by:

interceptOnHandle in interface MessageHandlerInterceptor<CommandMessage>

Parameters:

message - The message to intercept on handling.

context - The active processing context of the message being processed.

interceptorChain - The interceptor chain that allows this interceptor to proceed the dispatch process.

Returns:

The resulting message stream from MessageHandlerInterceptorChain.proceed(Message, ProcessingContext).