Package org.axonframework.extension.metrics.micrometer

Class MessageTimerMonitor

java.lang.Object

org.axonframework.extension.metrics.micrometer.MessageTimerMonitor

All Implemented Interfaces:

MessageMonitor<Message>

public class MessageTimerMonitor
extends Object
implements MessageMonitor<Message>

A MessageMonitor which introduces a Timer for the overall timer of all Messages being ingested, as well as a success, failure and ignored Timer.

Since:

4.1

Author:

Marijn van Zelst, Ivan Dugalic

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageTimerMonitor.Builder	Builder class to instantiate a MessageTimerMonitor.

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

MessageMonitor.MonitorCallback

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MessageTimerMonitor(MessageTimerMonitor.Builder builder)	Instantiate a MessageTimerMonitor based on the fields contained in the MessageTimerMonitor.Builder.

Method Summary

Modifier and Type	Method	Description
static MessageTimerMonitor.Builder	builder()	Instantiate a Builder to be able to create a MessageTimerMonitor.
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

MessageTimerMonitor

protected MessageTimerMonitor(MessageTimerMonitor.Builder builder)

Instantiate a MessageTimerMonitor based on the fields contained in the MessageTimerMonitor.Builder.

Will assert that the meterNamePrefix and MeterRegistry are not null and will throw an AxonConfigurationException if this is the case.

Parameters:

builder - the MessageTimerMonitor.Builder used to instantiate a MessageTimerMonitor instance

Method Details

builder

public static MessageTimerMonitor.Builder builder()

Instantiate a Builder to be able to create a MessageTimerMonitor.

The Clock is defaulted to a Clock.SYSTEM, the tagsBuilder to a Function returning Tags.empty() and the timerCustomization to a no-op. The meterNamePrefix and MeterRegistry are hard requirements and as such should be provided.

Returns:

a Builder to be able to create a MessageTimerMonitor

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