org.axonframework.eventhandling
Class EventProcessingMonitorCollection

java.lang.Object
  org.axonframework.eventhandling.EventProcessingMonitorCollection

All Implemented Interfaces:

EventProcessingMonitor, EventProcessingMonitorSupport

public class EventProcessingMonitorCollection
extends Object
implements EventProcessingMonitor, EventProcessingMonitorSupport

Implementation of the EventProcessingMonitor that delegates to all registered EventProcessingMonitor instances.

Since:

2.1

Author:

Allard Buijze

Constructor Summary

EventProcessingMonitorCollection()

Method Summary

void	onEventProcessingCompleted(List<? extends EventMessage> eventMessages) Invoked when one or more events have been successfully processed by the instance it was subscribed to.
void	onEventProcessingFailed(List<? extends EventMessage> eventMessages, Throwable cause) Invoked when one or more events have failed processing by the instance it was subscribed to.
void	subscribeEventProcessingMonitor(EventProcessingMonitor monitor) Subscribes the given monitor.
void	unsubscribeEventProcessingMonitor(EventProcessingMonitor monitor) Unsubscribed the given monitor.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventProcessingMonitorCollection

public EventProcessingMonitorCollection()

Method Detail

onEventProcessingCompleted

public void onEventProcessingCompleted(List<? extends EventMessage> eventMessages)

Description copied from interface: EventProcessingMonitor

Invoked when one or more events have been successfully processed by the instance it was subscribed to.

Specified by:

onEventProcessingCompleted in interface EventProcessingMonitor

Parameters:

eventMessages - The messages that have been successfully processed

onEventProcessingFailed

public void onEventProcessingFailed(List<? extends EventMessage> eventMessages,
                                    Throwable cause)

Description copied from interface: EventProcessingMonitor

Invoked when one or more events have failed processing by the instance it was subscribed to.

Specified by:

onEventProcessingFailed in interface EventProcessingMonitor

Parameters:

eventMessages - The message that failed

cause - The cause of the failure

subscribeEventProcessingMonitor

public void subscribeEventProcessingMonitor(EventProcessingMonitor monitor)

Description copied from interface: EventProcessingMonitorSupport

Subscribes the given monitor. If the monitor is already subscribed, nothing happens.

Specified by:

subscribeEventProcessingMonitor in interface EventProcessingMonitorSupport

Parameters:

monitor - The monitor to subscribe

unsubscribeEventProcessingMonitor

public void unsubscribeEventProcessingMonitor(EventProcessingMonitor monitor)

Description copied from interface: EventProcessingMonitorSupport

Unsubscribed the given monitor. If the monitor was not subscribed, or was already unsubscribed, nothing happens.

Specified by:

unsubscribeEventProcessingMonitor in interface EventProcessingMonitorSupport

Parameters:

monitor - The monitor to unsubscribe