io.micronaut.configuration.rabbitmq.metrics

Class RabbitMetricsInterceptor

java.lang.Object

io.micronaut.configuration.rabbitmq.metrics.RabbitMetricsInterceptor

All Implemented Interfaces:

io.micronaut.context.event.BeanCreatedEventListener<com.rabbitmq.client.ConnectionFactory>, java.util.EventListener

@Singleton
 @RequiresMetrics
 @Requires(property="micronaut.metrics.binders.rabbitmq.enabled",
          notEquals="false")
public class RabbitMetricsInterceptor
extends java.lang.Object
implements io.micronaut.context.event.BeanCreatedEventListener<com.rabbitmq.client.ConnectionFactory>

Interceptor of the connection factory to set the metrics collector.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
RabbitMetricsInterceptor(javax.inject.Provider<io.micrometer.core.instrument.MeterRegistry> meterRegistryProvider, java.lang.String prefix, java.util.Map<java.lang.String,java.lang.String> tags) Default constructor.

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.ConnectionFactory	onCreated(io.micronaut.context.event.BeanCreatedEvent<com.rabbitmq.client.ConnectionFactory> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMetricsInterceptor

public RabbitMetricsInterceptor(javax.inject.Provider<io.micrometer.core.instrument.MeterRegistry> meterRegistryProvider,
                                @Nullable @Property(name="micronaut.metrics.binders.rabbitmq.prefix")
                                java.lang.String prefix,
                                @Property(name="micronaut.metrics.binders.rabbitmq.tags") @MapFormat(transformation=FLAT)
                                java.util.Map<java.lang.String,java.lang.String> tags)

Default constructor.

Parameters:

prefix - The prefix

meterRegistryProvider - The meter registry provider

tags - The tags

Method Detail

onCreated

public com.rabbitmq.client.ConnectionFactory onCreated(io.micronaut.context.event.BeanCreatedEvent<com.rabbitmq.client.ConnectionFactory> event)

Specified by:

onCreated in interface io.micronaut.context.event.BeanCreatedEventListener<com.rabbitmq.client.ConnectionFactory>