org.apache.streams.pojo.json

Class ThroughputQueueBroadcast

java.lang.Object

org.apache.streams.pojo.json.Broadcast

org.apache.streams.pojo.json.ThroughputQueueBroadcast

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class ThroughputQueueBroadcast
extends Broadcast
implements Serializable

object

Snapshot of a ThroughputQueue's performance

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ThroughputQueueBroadcast()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Long	getAdded() Number of elements added to the queue
Map<String,Object>	getAdditionalProperties()
Object	getAvgWait() Average wait time
Long	getCurrentSize() Current size of the queue
Object	getMaxWait() Maximum wait time
String	getName() Name of the MBean
Long	getRemoved() Number of elements removed from the queue
Object	getThroughput() Number of elements that have passed through the queue per second
int	hashCode()
void	setAdded(Long added) Number of elements added to the queue
void	setAdditionalProperty(String name, Object value)
void	setAvgWait(Object avgWait) Average wait time
void	setCurrentSize(Long currentSize) Current size of the queue
void	setMaxWait(Object maxWait) Maximum wait time
void	setName(String name) Name of the MBean
void	setRemoved(Long removed) Number of elements removed from the queue
void	setThroughput(Object throughput) Number of elements that have passed through the queue per second
String	toString()
ThroughputQueueBroadcast	withAdded(Long added)
ThroughputQueueBroadcast	withAdditionalProperty(String name, Object value)
ThroughputQueueBroadcast	withAvgWait(Object avgWait)
ThroughputQueueBroadcast	withCurrentSize(Long currentSize)
ThroughputQueueBroadcast	withMaxWait(Object maxWait)
ThroughputQueueBroadcast	withName(String name)
ThroughputQueueBroadcast	withRemoved(Long removed)
ThroughputQueueBroadcast	withThroughput(Object throughput)

Methods inherited from class org.apache.streams.pojo.json.Broadcast

getStartedAt, getStreamIdentifier, setStartedAt, setStreamIdentifier, withStartedAt, withStreamIdentifier

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ThroughputQueueBroadcast

public ThroughputQueueBroadcast()

Method Detail

getCurrentSize

@BeanProperty(value="currentSize")
public Long getCurrentSize()

Current size of the queue

Returns:

The currentSize

setCurrentSize

@BeanProperty(value="currentSize")
public void setCurrentSize(Long currentSize)

Current size of the queue

Parameters:

currentSize - The currentSize

withCurrentSize

public ThroughputQueueBroadcast withCurrentSize(Long currentSize)

getAvgWait

@BeanProperty(value="avgWait")
public Object getAvgWait()

Average wait time

Returns:

The avgWait

setAvgWait

@BeanProperty(value="avgWait")
public void setAvgWait(Object avgWait)

Average wait time

Parameters:

avgWait - The avgWait

withAvgWait

public ThroughputQueueBroadcast withAvgWait(Object avgWait)

getMaxWait

@BeanProperty(value="maxWait")
public Object getMaxWait()

Maximum wait time

Returns:

The maxWait

setMaxWait

@BeanProperty(value="maxWait")
public void setMaxWait(Object maxWait)

Maximum wait time

Parameters:

maxWait - The maxWait

withMaxWait

public ThroughputQueueBroadcast withMaxWait(Object maxWait)

getRemoved

@BeanProperty(value="removed")
public Long getRemoved()

Number of elements removed from the queue

Returns:

The removed

setRemoved

@BeanProperty(value="removed")
public void setRemoved(Long removed)

Number of elements removed from the queue

Parameters:

removed - The removed

withRemoved

public ThroughputQueueBroadcast withRemoved(Long removed)

getAdded

@BeanProperty(value="added")
public Long getAdded()

Number of elements added to the queue

Returns:

The added

setAdded

@BeanProperty(value="added")
public void setAdded(Long added)

Number of elements added to the queue

Parameters:

added - The added

withAdded

public ThroughputQueueBroadcast withAdded(Long added)

getThroughput

@BeanProperty(value="throughput")
public Object getThroughput()

Number of elements that have passed through the queue per second

Returns:

The throughput

setThroughput

@BeanProperty(value="throughput")
public void setThroughput(Object throughput)

Number of elements that have passed through the queue per second

Parameters:

throughput - The throughput

withThroughput

public ThroughputQueueBroadcast withThroughput(Object throughput)

getName

@BeanProperty(value="name")
public String getName()

Name of the MBean

Overrides:

getName in class Broadcast

Returns:

The name

setName

@BeanProperty(value="name")
public void setName(String name)

Name of the MBean

Overrides:

setName in class Broadcast

Parameters:

name - The name

withName

public ThroughputQueueBroadcast withName(String name)

Overrides:

withName in class Broadcast

toString

public String toString()

Overrides:

toString in class Broadcast

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class Broadcast

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

Overrides:

setAdditionalProperty in class Broadcast

withAdditionalProperty

public ThroughputQueueBroadcast withAdditionalProperty(String name,
                                                       Object value)

Overrides:

withAdditionalProperty in class Broadcast

hashCode

public int hashCode()

Overrides:

hashCode in class Broadcast

equals

public boolean equals(Object other)

Overrides:

equals in class Broadcast