org.axonframework.micrometer

Class PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>>

java.lang.Object

org.axonframework.micrometer.PayloadTypeMessageMonitorWrapper<T>

Type Parameters:

T - The type of the MessageMonitor created for every payload type.Must implement both MessageMonitor

All Implemented Interfaces:

MessageMonitor<Message<?>>

Deprecated.

As of release 4.4, replaced by using Tags on the monitor implementations. Use {@link org.axonframework.micrometer.GlobalMetricRegistry#registerWithConfigurerWithDefaultTags(Configurer) to achieve the same behavior as this implementation.

@Deprecated
public class PayloadTypeMessageMonitorWrapper<T extends MessageMonitor<Message<?>>>
extends Object
implements MessageMonitor<Message<?>>

A MessageMonitor implementation which creates a new MessageMonitor for every Message payload type ingested by it. The PayloadTypeMessageMonitorWrapper keeps track of all distinct payload types it has created and only creates a new one if there is none present.

The type of MessageMonitor which is created for every payload type is configurable, as long as it implements MessageMonitor}.

Since:

4.1

Author:

Steven van Beelen, Marijn van Zelst

Nested Class Summary

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

MessageMonitor.MonitorCallback

Constructor Summary

Constructors

Constructor and Description
PayloadTypeMessageMonitorWrapper(Function<String,T> monitorSupplier) Deprecated. Create a PayloadTypeMessageMonitorWrapper which builds monitors through a given monitorSupplier for every message payload type encountered.
PayloadTypeMessageMonitorWrapper(Function<String,T> monitorSupplier, Function<Class<?>,String> monitorNameBuilder) Deprecated. Create a PayloadTypeMessageMonitorWrapper which builds monitors through a given monitorSupplier for every message payload type encountered and sets the monitor name as specified by the monitorNameBuilder.

Method Summary

Modifier and Type	Method and Description
MessageMonitor.MonitorCallback	onMessageIngested(Message<?> message) Deprecated. 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.monitoring.MessageMonitor

onMessagesIngested

Constructor Detail

PayloadTypeMessageMonitorWrapper

public PayloadTypeMessageMonitorWrapper(Function<String,T> monitorSupplier)

Deprecated.

Create a PayloadTypeMessageMonitorWrapper which builds monitors through a given monitorSupplier for every message payload type encountered.

Parameters:

monitorSupplier - A Supplier of MessageMonitors of type T for every encountered payload type

PayloadTypeMessageMonitorWrapper

public PayloadTypeMessageMonitorWrapper(Function<String,T> monitorSupplier,
                                        Function<Class<?>,String> monitorNameBuilder)

Deprecated.

Create a PayloadTypeMessageMonitorWrapper which builds monitors through a given monitorSupplier for every message payload type encountered and sets the monitor name as specified by the monitorNameBuilder.

Parameters:

monitorSupplier - A Function to create a MessageMonitor of type T, with the given String as name, for every encountered payload type

monitorNameBuilder - A Function where the payload type is the input (of type Class<?>) and output is the desired name for the monitor (of type String)

Method Detail

onMessageIngested

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

Deprecated.

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