org.apache.storm.utils

Class JCQueue.QueueMetrics

java.lang.Object

org.apache.storm.utils.JCQueue.QueueMetrics

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

JCQueue

public class JCQueue.QueueMetrics
extends Object
implements Closeable

This inner class provides methods to access the metrics of the JCQueue.

Constructor Summary

Constructors

Constructor and Description
QueueMetrics()

Method Summary

Modifier and Type	Method and Description
long	capacity()
void	close()
Object	getState()
void	notifyArrivals(long counts)
void	notifyDroppedMsg()
void	notifyInsertFailure()
long	population()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueMetrics

public QueueMetrics()

Method Detail

population

public long population()

capacity

public long capacity()

getState

public Object getState()

notifyArrivals

public void notifyArrivals(long counts)

notifyInsertFailure

public void notifyInsertFailure()

notifyDroppedMsg

public void notifyDroppedMsg()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable