org.axonframework.metrics

Class MessageTimerMonitor

java.lang.Object

org.axonframework.metrics.MessageTimerMonitor

All Implemented Interfaces:

com.codahale.metrics.Metric, com.codahale.metrics.MetricSet, MessageMonitor<Message<?>>

public class MessageTimerMonitor
extends Object
implements MessageMonitor<Message<?>>, com.codahale.metrics.MetricSet

Times allTimer messages, successful and failed messages

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
MessageTimerMonitor() Creates a MessageTimerMonitor using a default clock
MessageTimerMonitor(com.codahale.metrics.Clock clock) Creates a MessageTimerMonitor using the provided clock

Method Summary

Modifier and Type	Method and Description
Map<String,com.codahale.metrics.Metric>	getMetrics()
MessageMonitor.MonitorCallback	onMessageIngested(Message<?> message) Takes a message and returns a callback that should be used to inform the message monitor about the result of processing the message

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageTimerMonitor

public MessageTimerMonitor()

Creates a MessageTimerMonitor using a default clock

MessageTimerMonitor

public MessageTimerMonitor(com.codahale.metrics.Clock clock)

Creates a MessageTimerMonitor using the provided clock

Parameters:

clock - the clock used to measure the process time of each message

Method Detail

onMessageIngested

public MessageMonitor.MonitorCallback onMessageIngested(Message<?> message)

Description copied from interface: MessageMonitor

Takes a message and returns a callback that should be used to inform the message monitor about the result of processing the message

Specified by:

onMessageIngested in interface MessageMonitor<Message<?>>

Parameters:

message - the message to monitor

Returns:

the callback

getMetrics

public Map<String,com.codahale.metrics.Metric> getMetrics()

Specified by:

getMetrics in interface com.codahale.metrics.MetricSet