Package com.rabbitmq.client
Interface MetricsCollector
-
- All Known Implementing Classes:
AbstractMetricsCollector
,MicrometerMetricsCollector
,NoOpMetricsCollector
,StandardMetricsCollector
public interface MetricsCollector
Interface to gather execution data of the client. Note transactions are not supported: they deal with publishing and acknowledgments and the collector contract assumes then that published messages and acks sent in a transaction are always counted, even if the transaction is rolled back.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
basicAck(Channel channel, long deliveryTag, boolean multiple)
void
basicCancel(Channel channel, String consumerTag)
void
basicConsume(Channel channel, String consumerTag, boolean autoAck)
void
basicNack(Channel channel, long deliveryTag)
void
basicPublish(Channel channel)
default void
basicPublishAck(Channel channel, long deliveryTag, boolean multiple)
default void
basicPublishFailure(Channel channel, Throwable cause)
default void
basicPublishNack(Channel channel, long deliveryTag, boolean multiple)
default void
basicPublishUnrouted(Channel channel)
void
basicReject(Channel channel, long deliveryTag)
void
closeChannel(Channel channel)
void
closeConnection(Connection connection)
void
consumedMessage(Channel channel, long deliveryTag, boolean autoAck)
void
consumedMessage(Channel channel, long deliveryTag, String consumerTag)
void
newChannel(Channel channel)
void
newConnection(Connection connection)
-
-
-
Method Detail
-
newConnection
void newConnection(Connection connection)
-
closeConnection
void closeConnection(Connection connection)
-
newChannel
void newChannel(Channel channel)
-
closeChannel
void closeChannel(Channel channel)
-
basicPublish
void basicPublish(Channel channel)
-
basicPublishAck
default void basicPublishAck(Channel channel, long deliveryTag, boolean multiple)
-
basicPublishNack
default void basicPublishNack(Channel channel, long deliveryTag, boolean multiple)
-
basicPublishUnrouted
default void basicPublishUnrouted(Channel channel)
-
consumedMessage
void consumedMessage(Channel channel, long deliveryTag, boolean autoAck)
-
basicAck
void basicAck(Channel channel, long deliveryTag, boolean multiple)
-
basicNack
void basicNack(Channel channel, long deliveryTag)
-
basicReject
void basicReject(Channel channel, long deliveryTag)
-
-