Package org.axonframework.messaging.monitoring.interception

Class MonitoringEventDispatchInterceptor

java.lang.Object

org.axonframework.messaging.monitoring.interception.MonitoringEventDispatchInterceptor

All Implemented Interfaces:

MessageDispatchInterceptor<EventMessage>

public class MonitoringEventDispatchInterceptor
extends Object
implements MessageDispatchInterceptor<EventMessage>

A MessageDispatchInterceptor that intercepts a MessageDispatchInterceptorChain of EventMessage and registers the MessageMonitor.MonitorCallback hooks for reporting. Invoked by the InterceptingEventSink.

Since:

5.0.0

Author:

Jan Galinski

Constructor Summary

Constructors

Constructor	Description
MonitoringEventDispatchInterceptor(MessageMonitor<? super EventMessage> messageMonitor)	Constructs a new MonitoringEventDispatchInterceptor using the given MessageMonitor.

Method Summary

Modifier and Type	Method	Description
MessageStream<?>	interceptOnDispatch(EventMessage message, ProcessingContext context, MessageDispatchInterceptorChain<EventMessage> interceptorChain)	Intercepts a given message on dispatching.

Methods inherited from class java.lang.Object

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

Constructor Details

MonitoringEventDispatchInterceptor

public MonitoringEventDispatchInterceptor(@Nonnull
 MessageMonitor<? super EventMessage> messageMonitor)

Constructs a new MonitoringEventDispatchInterceptor using the given MessageMonitor.

Parameters:

messageMonitor - The MessageMonitor instance used for reporting.

Method Details

interceptOnDispatch

@Nonnull
public MessageStream<?> interceptOnDispatch(@Nonnull
 EventMessage message,
 @Nullable
 ProcessingContext context,
 @Nonnull
 MessageDispatchInterceptorChain<EventMessage> interceptorChain)

Description copied from interface: MessageDispatchInterceptor

Intercepts a given message on dispatching.

The implementer of this method might want to intercept the message before passing it to the chain (effectively before calling MessageDispatchInterceptorChain.proceed(Message, ProcessingContext)) or after the chain (by mapping the resulting message by calling MessageStream.mapMessage(Function)).

Specified by:

interceptOnDispatch in interface MessageDispatchInterceptor<EventMessage>

Parameters:

message - The message to intercept on dispatching.

context - The active processing context, if any. Can be used to (e.g.) validate correlation data.

interceptorChain - The interceptor chain to signal that processing is finished and further interceptors should be called.

Returns:

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