org.apache.streams.local.queues

Interface ThroughputQueueMXBean

All Known Implementing Classes:

ThroughputQueue

public interface ThroughputQueueMXBean

MXBean capable queue that monitors the throughput of the queue

Method Summary

Modifier and Type	Method and Description
long	getAdded() Get the number of items that have been added to the queue
double	getAvgWait() Get the average time an item spends in queue in milliseconds
long	getCurrentSize() Returns the number of items on the queue.
long	getMaxWait() Get the maximum time an item has spent on the queue before being removed from the queue.
long	getRemoved() Get the number of items that have been removed from this queue
double	getThroughput() Get the the throughput of the queue measured by the number of items removed from the queue dived by the time the queue has been active.

Method Detail

getCurrentSize

long getCurrentSize()

Returns the number of items on the queue.

Returns:

number of items on queue

getAvgWait

double getAvgWait()

Get the average time an item spends in queue in milliseconds

Returns:

average time an item spends in queue in milliseconds

getMaxWait

long getMaxWait()

Get the maximum time an item has spent on the queue before being removed from the queue.

Returns:

the maximum time an item has spent on the queue

getRemoved

long getRemoved()

Get the number of items that have been removed from this queue

Returns:

number of items that have been removed from the queue

getAdded

long getAdded()

Get the number of items that have been added to the queue

Returns:

number of items that have been added to the queue

getThroughput

double getThroughput()

Get the the throughput of the queue measured by the number of items removed from the queue dived by the time the queue has been active. Active time starts once the first item has been placed on the queue

Returns:

throughput of queue. items/sec, items removed / time active