org.axonframework.monitoring

Class MultiMessageMonitor<T extends Message<?>>

java.lang.Object

org.axonframework.monitoring.MultiMessageMonitor<T>

All Implemented Interfaces:

MessageMonitor<T>

public class MultiMessageMonitor<T extends Message<?>>
extends Object
implements MessageMonitor<T>

Delegates messages and callbacks to the given list of message monitors

Since:

3.0

Author:

Marijn van Zelst

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.monitoring.MessageMonitor

MessageMonitor.MonitorCallback

Constructor Summary

Constructors

Constructor and Description
MultiMessageMonitor(List<MessageMonitor<? super T>> messageMonitors) Initialize a message monitor with the given list of messageMonitors
MultiMessageMonitor(MessageMonitor<? super T>... messageMonitors) Initialize a message monitor with the given messageMonitors

Method Summary

Modifier and Type	Method and Description
MessageMonitor.MonitorCallback	onMessageIngested(T message) Calls the message monitors with the given message and returns a callback that will trigger all the message monitor callbacks

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiMessageMonitor

@SafeVarargs
public MultiMessageMonitor(MessageMonitor<? super T>... messageMonitors)

Initialize a message monitor with the given messageMonitors

Parameters:

messageMonitors - the list of event monitors to delegate to

MultiMessageMonitor

public MultiMessageMonitor(List<MessageMonitor<? super T>> messageMonitors)

Initialize a message monitor with the given list of messageMonitors

Parameters:

messageMonitors - the list of event monitors to delegate to

Method Detail

onMessageIngested

public MessageMonitor.MonitorCallback onMessageIngested(T message)

Calls the message monitors with the given message and returns a callback that will trigger all the message monitor callbacks

Specified by:

onMessageIngested in interface MessageMonitor<T extends Message<?>>

Parameters:

message - the message to delegate to the message monitors

Returns:

the callback that will trigger all the message monitor callbacks