Class MicrometerMetricsCollector

java.lang.Object

com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector

All Implemented Interfaces:

MetricsCollector

public class MicrometerMetricsCollector
extends Object
implements MetricsCollector

MetricsCollector implementation using Micrometer.

Nested Class Summary

Nested classes/interfaces inherited from interface MetricsCollector

MetricsCollector.ConsumeDisposition, MetricsCollector.PublishDisposition

Constructor Summary

Constructors

Constructor	Description
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix, Iterable<io.micrometer.core.instrument.Tag> tags)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix, String... tags)

Method Summary

Modifier and Type	Method	Description
void	closeConnection()	Called when a Connection is closed.
void	closeConsumer()	Called when a Consumer is closed.
void	closePublisher()	Called when a Publisher is closed.
void	consume()	Called when a Message is dispatched to a Consumer.
void	consumeDisposition(MetricsCollector.ConsumeDisposition disposition)	Called when a Message is settled by a Consumer.
void	openConnection()	Called when a new Connection is opened.
void	openConsumer()	Called when a new Consumer is opened.
void	openPublisher()	Called when a new Publisher is opened.
void	publish()	Called when a Message is published.
void	publishDisposition(MetricsCollector.PublishDisposition disposition)	Called when a Message is settled by the broker.
void	readBytes(int readBytes)	Called when a connection reads bytes from its socket.
void	writtenBytes(int writtenBytes)	Called when a connection writes bytes to its socket.

Methods inherited from class Object

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

Constructor Details

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 String... tags)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 Iterable<io.micrometer.core.instrument.Tag> tags)

Method Details

openConnection

public void openConnection()

Description copied from interface: MetricsCollector

Called when a new Connection is opened.

Specified by:

openConnection in interface MetricsCollector

closeConnection

public void closeConnection()

Description copied from interface: MetricsCollector

Called when a Connection is closed.

Specified by:

closeConnection in interface MetricsCollector

openPublisher

public void openPublisher()

Description copied from interface: MetricsCollector

Called when a new Publisher is opened.

Specified by:

openPublisher in interface MetricsCollector

closePublisher

public void closePublisher()

Description copied from interface: MetricsCollector

Called when a Publisher is closed.

Specified by:

closePublisher in interface MetricsCollector

openConsumer

public void openConsumer()

Description copied from interface: MetricsCollector

Called when a new Consumer is opened.

Specified by:

openConsumer in interface MetricsCollector

closeConsumer

public void closeConsumer()

Description copied from interface: MetricsCollector

Called when a Consumer is closed.

Specified by:

closeConsumer in interface MetricsCollector

publish

public void publish()

Description copied from interface: MetricsCollector

Called when a Message is published.

Specified by:

publish in interface MetricsCollector

publishDisposition

public void publishDisposition(MetricsCollector.PublishDisposition disposition)

Description copied from interface: MetricsCollector

Called when a Message is settled by the broker.

Specified by:

publishDisposition in interface MetricsCollector

Parameters:

disposition - disposition (outcome)

consume

public void consume()

Description copied from interface: MetricsCollector

Called when a Message is dispatched to a Consumer.

Specified by:

consume in interface MetricsCollector

consumeDisposition

public void consumeDisposition(MetricsCollector.ConsumeDisposition disposition)

Description copied from interface: MetricsCollector

Called when a Message is settled by a Consumer.

Specified by:

consumeDisposition in interface MetricsCollector

Parameters:

disposition -

writtenBytes

public void writtenBytes(int writtenBytes)

Description copied from interface: MetricsCollector

Called when a connection writes bytes to its socket.

Specified by:

writtenBytes in interface MetricsCollector

Parameters:

writtenBytes - the number of written bytes

readBytes

public void readBytes(int readBytes)

Description copied from interface: MetricsCollector

Called when a connection reads bytes from its socket.

Specified by:

readBytes in interface MetricsCollector

Parameters:

readBytes - the number of read bytes