Package com.rabbitmq.client.impl

Class AbstractMetricsCollector

  • All Implemented Interfaces:
    MetricsCollector
    public abstract class AbstractMetricsCollector
extends java.lang.Object
implements MetricsCollector
    Base class for MetricsCollector. Implements tricky logic such as keeping track of acknowledged and rejected messages. Sub-classes just need to implement the logic to increment their metrics. Note transactions are not supported (see MetricsCollector.
    See Also:
    MetricsCollector

    • Field Detail

      • LOGGER

        private static final org.slf4j.Logger LOGGER

      • markAcknowledgedMessageAction

        private final java.lang.Runnable markAcknowledgedMessageAction

      • markRejectedMessageAction

        private final java.lang.Runnable markRejectedMessageAction

    • Constructor Detail

      • AbstractMetricsCollector

        public AbstractMetricsCollector()

    • Method Detail

      • updateChannelStateAfterAckReject

        private void updateChannelStateAfterAckReject​(Channel channel,
                                              long deliveryTag,
                                              boolean multiple,
                                              java.lang.Runnable action)

      • cleanStaleState

        public void cleanStaleState()
        Clean inner state for close connections and channels. Inner state is automatically cleaned on connection and channel closing. Thus, this method is provided as a safety net, to be externally called periodically if closing of resources wouldn't work properly for some corner cases.

      • incrementConnectionCount

        protected abstract void incrementConnectionCount​(Connection connection)
        Increments connection count. The connection object is passed in as complementary information and without any guarantee of not being null.
        Parameters:
        connection - the connection that has been created (can be null)

      • decrementConnectionCount

        protected abstract void decrementConnectionCount​(Connection connection)
        Decrements connection count. The connection object is passed in as complementary information and without any guarantee of not being null.
        Parameters:
        connection - the connection that has been closed (can be null)

      • incrementChannelCount

        protected abstract void incrementChannelCount​(Channel channel)
        Increments channel count. The channel object is passed in as complementary information and without any guarantee of not being null.
        Parameters:
        channel - the channel that has been created (can be null)

      • decrementChannelCount

        protected abstract void decrementChannelCount​(Channel channel)
        Decrements channel count. The channel object is passed in as complementary information and without any guarantee of not being null.
        Parameters:
        channel -

      • markPublishedMessage

        protected abstract void markPublishedMessage()
        Marks the event of a published message.

      • markMessagePublishFailed

        protected abstract void markMessagePublishFailed()
        Marks the event of a message publishing failure.

      • markConsumedMessage

        protected abstract void markConsumedMessage()
        Marks the event of a consumed message.

      • markAcknowledgedMessage

        protected abstract void markAcknowledgedMessage()
        Marks the event of an acknowledged message.

      • markRejectedMessage

        protected abstract void markRejectedMessage()
        Marks the event of a rejected message.

      • markMessagePublishAcknowledged

        protected abstract void markMessagePublishAcknowledged()
        Marks the event of a message publishing acknowledgement.

      • markMessagePublishNotAcknowledged

        protected abstract void markMessagePublishNotAcknowledged()
        Marks the event of a message publishing not being acknowledged.

      • markPublishedMessageUnrouted

        protected abstract void markPublishedMessageUnrouted()
        Marks the event of a published message not being routed.