Package com.rabbitmq.client.impl

Class StandardMetricsCollector

java.lang.Object
com.rabbitmq.client.impl.AbstractMetricsCollector
com.rabbitmq.client.impl.StandardMetricsCollector
All Implemented Interfaces:
MetricsCollector
public class StandardMetricsCollector extends AbstractMetricsCollector
Dropwizard Metrics implementation of MetricsCollector. Note transactions are not supported (see MetricsCollector. Metrics provides out-of-the-box support for report backends like JMX, Graphite, Ganglia, or plain HTTP. See Metrics documentation for more details.
See Also:

  • Constructor Details

    • StandardMetricsCollector

      public StandardMetricsCollector(com.codahale.metrics.MetricRegistry registry, String metricsPrefix)

    • StandardMetricsCollector

      public StandardMetricsCollector()

    • StandardMetricsCollector

      public StandardMetricsCollector(com.codahale.metrics.MetricRegistry metricRegistry)

  • Method Details

    • incrementConnectionCount

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

    • decrementConnectionCount

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

    • incrementChannelCount

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

    • decrementChannelCount

      protected void decrementChannelCount(Channel channel)
      Description copied from class: AbstractMetricsCollector
      Decrements channel count. The channel object is passed in as complementary information and without any guarantee of not being null.
      Specified by:
      decrementChannelCount in class AbstractMetricsCollector
      Parameters:
      channel -

    • markPublishedMessage

      protected void markPublishedMessage()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a published message.
      Specified by:
      markPublishedMessage in class AbstractMetricsCollector

    • markMessagePublishFailed

      protected void markMessagePublishFailed()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a message publishing failure.
      Specified by:
      markMessagePublishFailed in class AbstractMetricsCollector

    • markConsumedMessage

      protected void markConsumedMessage()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a consumed message.
      Specified by:
      markConsumedMessage in class AbstractMetricsCollector

    • markAcknowledgedMessage

      protected void markAcknowledgedMessage()
      Description copied from class: AbstractMetricsCollector
      Marks the event of an acknowledged message.
      Specified by:
      markAcknowledgedMessage in class AbstractMetricsCollector

    • markRejectedMessage

      protected void markRejectedMessage()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a rejected message.
      Specified by:
      markRejectedMessage in class AbstractMetricsCollector

    • markRejectedMessage

      protected void markRejectedMessage(boolean requeue)
      Description copied from class: AbstractMetricsCollector
      Marks the event of a rejected message.
      Overrides:
      markRejectedMessage in class AbstractMetricsCollector

    • markMessagePublishAcknowledged

      protected void markMessagePublishAcknowledged()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a message publishing acknowledgement.
      Specified by:
      markMessagePublishAcknowledged in class AbstractMetricsCollector

    • markMessagePublishNotAcknowledged

      protected void markMessagePublishNotAcknowledged()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a message publishing not being acknowledged.
      Specified by:
      markMessagePublishNotAcknowledged in class AbstractMetricsCollector

    • markPublishedMessageUnrouted

      protected void markPublishedMessageUnrouted()
      Description copied from class: AbstractMetricsCollector
      Marks the event of a published message not being routed.
      Specified by:
      markPublishedMessageUnrouted in class AbstractMetricsCollector

    • getMetricRegistry

      public com.codahale.metrics.MetricRegistry getMetricRegistry()

    • getConnections

      public com.codahale.metrics.Counter getConnections()

    • getChannels

      public com.codahale.metrics.Counter getChannels()

    • getPublishedMessages

      public com.codahale.metrics.Meter getPublishedMessages()

    • getConsumedMessages

      public com.codahale.metrics.Meter getConsumedMessages()

    • getAcknowledgedMessages

      public com.codahale.metrics.Meter getAcknowledgedMessages()

    • getRejectedMessages

      public com.codahale.metrics.Meter getRejectedMessages()

    • getRequeuedMessages

      public com.codahale.metrics.Meter getRequeuedMessages()

    • getFailedToPublishMessages

      public com.codahale.metrics.Meter getFailedToPublishMessages()

    • getPublishAcknowledgedMessages

      public com.codahale.metrics.Meter getPublishAcknowledgedMessages()

    • getPublishNotAcknowledgedMessages

      public com.codahale.metrics.Meter getPublishNotAcknowledgedMessages()

    • getPublishUnroutedMessages

      public com.codahale.metrics.Meter getPublishUnroutedMessages()