Class JCQueueMetrics

java.lang.Object
org.apache.storm.utils.JCQueueMetrics
All Implemented Interfaces:
Closeable, AutoCloseable

public class JCQueueMetrics extends Object implements Closeable
  • Constructor Details

    • JCQueueMetrics

      public JCQueueMetrics(String metricNamePrefix, String topologyId, String componentId, int taskId, int port, StormMetricRegistry metricRegistry, org.apache.storm.shade.org.jctools.queues.MpscArrayQueue<Object> receiveQ, org.apache.storm.shade.org.jctools.queues.MpscUnboundedArrayQueue<Object> overflowQ)
  • Method Details

    • notifyArrivals

      public void notifyArrivals(long counts)
    • notifyInsertFailure

      public void notifyInsertFailure()
    • notifyDroppedMsg

      public void notifyDroppedMsg()
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable