com.massa.mrules.extensions.monitoring.micrometer

Class AbstractMRulesMetrics

java.lang.Object

com.massa.mrules.extensions.monitoring.micrometer.AbstractMRulesMetrics

All Implemented Interfaces:

io.micrometer.core.instrument.binder.MeterBinder, AutoCloseable

Direct Known Subclasses:

MRulesDetailedMetrics, MRulesMetrics

public abstract class AbstractMRulesMetrics
extends Object
implements io.micrometer.core.instrument.binder.MeterBinder, AutoCloseable

Base implementation which allows to bind metrics collectors to MBeans exposed by MRules rulesets via the MBeanServer.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Runnable>	closeHooks
protected double	convertionRatio
static String	JMX_DOMAIN JMX prefix for MRules
protected MBeanServer	mBeanServer
static String	METRIC_NAME_PREFIX Metrics prefix for MRules

Constructor Summary

Constructors

Constructor and Description
AbstractMRulesMetrics() Constructor
AbstractMRulesMetrics(MBeanServer mBeanServer) Constructor
AbstractMRulesMetrics(MBeanServer mBeanServer, TimeUnit timeUnit) Constructor
AbstractMRulesMetrics(TimeUnit timeUnit) Constructor

Method Summary

Modifier and Type	Method and Description
void	bindTo(io.micrometer.core.instrument.MeterRegistry registry)
void	close()
static MBeanServer	getDefaultMBeanServer() Retrieves default MBean Server.
protected abstract void	perObject(io.micrometer.core.instrument.MeterRegistry registry, ObjectName objectName)
protected void	registerListener(ObjectName objectName, NotificationListener notificationListener, NotificationFilter filter) Registers a MBean listener and prepares the related close hook.
protected void	registerNotificationListener(io.micrometer.core.instrument.MeterRegistry registry, java.util.function.BiConsumer<io.micrometer.core.instrument.MeterRegistry,ObjectName> perObject) Prepares an registers the listener for new MBeans and prepares the related close hook.

Methods inherited from class java.lang.Object

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

Field Detail

JMX_DOMAIN

public static final String JMX_DOMAIN

JMX prefix for MRules

See Also:

Constant Field Values

METRIC_NAME_PREFIX

public static final String METRIC_NAME_PREFIX

Metrics prefix for MRules

See Also:

Constant Field Values

mBeanServer

protected final MBeanServer mBeanServer

convertionRatio

protected final double convertionRatio

closeHooks

protected final List<Runnable> closeHooks

Constructor Detail

AbstractMRulesMetrics

public AbstractMRulesMetrics()

Constructor

AbstractMRulesMetrics

public AbstractMRulesMetrics(TimeUnit timeUnit)

Constructor

Parameters:

timeUnit -

AbstractMRulesMetrics

public AbstractMRulesMetrics(MBeanServer mBeanServer)

Constructor

Parameters:

mBeanServer -

AbstractMRulesMetrics

public AbstractMRulesMetrics(MBeanServer mBeanServer,
                             TimeUnit timeUnit)

Constructor

Parameters:

mBeanServer -

timeUnit -

Method Detail

getDefaultMBeanServer

public static MBeanServer getDefaultMBeanServer()

Retrieves default MBean Server.

Returns:

MBeanServer

bindTo

public void bindTo(@NonNull
                   io.micrometer.core.instrument.MeterRegistry registry)

Specified by:

bindTo in interface io.micrometer.core.instrument.binder.MeterBinder

perObject

protected abstract void perObject(io.micrometer.core.instrument.MeterRegistry registry,
                                  ObjectName objectName)

registerNotificationListener

protected void registerNotificationListener(io.micrometer.core.instrument.MeterRegistry registry,
                                            java.util.function.BiConsumer<io.micrometer.core.instrument.MeterRegistry,ObjectName> perObject)

Prepares an registers the listener for new MBeans and prepares the related close hook. perObject(MeterRegistry, ObjectName) will be invoked for each new MBean.

registerListener

protected void registerListener(ObjectName objectName,
                                NotificationListener notificationListener,
                                NotificationFilter filter)

Registers a MBean listener and prepares the related close hook.

close

public void close()

Specified by:

close in interface AutoCloseable