Package org.apache.storm.utils
Class JCQueueMetrics
java.lang.Object
org.apache.storm.utils.JCQueueMetrics
- All Implemented Interfaces:
Closeable
,AutoCloseable
-
Constructor Summary
ConstructorDescriptionJCQueueMetrics
(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 Summary
-
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 interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
-