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

Methods inherited from interface org.axonframework.monitoring.MessageMonitor

onMessagesIngested

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(@Nonnull
                                                        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