Package org.axonframework.extension.metrics.dropwizard

Class MessageCountingMonitor

java.lang.Object

org.axonframework.extension.metrics.dropwizard.MessageCountingMonitor

All Implemented Interfaces:

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

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

Counts the number of ingested, successful, failed and processed messages

Since:

3.0

Author:

Marijn van Zelst

Nested Class Summary

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

MessageMonitor.MonitorCallback

Constructor Summary

Constructors

Constructor	Description
MessageCountingMonitor()

Method Summary

Modifier and Type	Method	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

Methods inherited from interface org.axonframework.messaging.monitoring.MessageMonitor

onMessagesIngested

Constructor Details

MessageCountingMonitor

public MessageCountingMonitor()

Method Details

onMessageIngested

public MessageMonitor.MonitorCallback onMessageIngested(@Nonnull
 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