org.perf.log.logger
Class LogQueueMetricTracker

java.lang.Object
  extended by org.perf.log.logger.LogQueueMetricTracker

public class LogQueueMetricTracker
extends java.lang.Object

Author:
Pradeep Nambiar 2/10/2012

Constructor Summary
LogQueueMetricTracker()
           
 
Method Summary
 void decrementSize()
           
 long getDeQueued()
           
 long getDequeueIntervalStartTime()
           
 long getDequeueRate()
           
 long getEnQueued()
           
 long getEnqueueIntervalStartTime()
           
 long getEnqueueRate()
           
 long getMaxDequeueRate()
           
 long getMaxEnqueueRate()
           
 long getNumDropped()
           
 long getNumErrored()
           
 long getQSize()
           
 long getRateCheckInterval()
           
 java.lang.String getStats()
           
 java.lang.Thread getThreadManagingThisQueue()
           
 void incrementNumDropped()
           
 void incrementNumErrored()
           
 void incrementSize()
           
 boolean isThreadManagingThisQueueIsSleeping()
           
 void setThreadManagingThisQueue(java.lang.Thread threadManagingThisQueue)
           
 void setThreadManagingThisQueueIsSleeping(boolean threadManagingThisQueueIsSleeping)
           
 java.lang.String toString()
           
 void updateDequeueRate()
           
 void updateEnqueueAndDequeueRate()
           
 void updateEnqueueRate()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

LogQueueMetricTracker

public LogQueueMetricTracker()
Method Detail

getQSize

public long getQSize()
Returns:
the qSize

incrementSize

public void incrementSize()

updateEnqueueRate

public void updateEnqueueRate()

updateDequeueRate

public void updateDequeueRate()

updateEnqueueAndDequeueRate

public void updateEnqueueAndDequeueRate()

decrementSize

public void decrementSize()

incrementNumDropped

public void incrementNumDropped()

incrementNumErrored

public void incrementNumErrored()

getEnqueueRate

public long getEnqueueRate()
Returns:
the enqueueRate

getDequeueRate

public long getDequeueRate()
Returns:
the dequeueRate

getEnQueued

public long getEnQueued()
Returns:
the enQueued

getDeQueued

public long getDeQueued()
Returns:
the deQueued

getEnqueueIntervalStartTime

public long getEnqueueIntervalStartTime()
Returns:
the enqueueIntervalStartTime

getDequeueIntervalStartTime

public long getDequeueIntervalStartTime()
Returns:
the dequeueIntervalStartTime

getRateCheckInterval

public long getRateCheckInterval()
Returns:
the interval

getMaxEnqueueRate

public long getMaxEnqueueRate()
Returns:
the maxEnqueueRate

getMaxDequeueRate

public long getMaxDequeueRate()
Returns:
the maxDequeueRate

getNumDropped

public long getNumDropped()
Returns:
the numDropped

getStats

public java.lang.String getStats()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

getThreadManagingThisQueue

public java.lang.Thread getThreadManagingThisQueue()

setThreadManagingThisQueue

public void setThreadManagingThisQueue(java.lang.Thread threadManagingThisQueue)

isThreadManagingThisQueueIsSleeping

public boolean isThreadManagingThisQueueIsSleeping()

setThreadManagingThisQueueIsSleeping

public void setThreadManagingThisQueueIsSleeping(boolean threadManagingThisQueueIsSleeping)

getNumErrored

public long getNumErrored()