public class MsgStats extends Object
Modifier and Type | Field and Description |
---|---|
protected LongAdder |
num_batches_received |
protected LongAdder |
num_batches_sent |
protected LongAdder |
num_bytes_received |
protected LongAdder |
num_bytes_sent |
protected LongAdder |
num_internal_msgs_received |
protected LongAdder |
num_msgs_received |
protected LongAdder |
num_msgs_sent |
protected LongAdder |
num_oob_msgs_received |
protected AtomicInteger |
num_rejected_msgs |
protected LongAdder |
num_single_msgs_sent |
protected AtomicInteger |
num_threads_spawned |
Constructor and Description |
---|
MsgStats() |
Modifier and Type | Method and Description |
---|---|
long |
getNumBatchesReceived() |
long |
getNumBatchesSent() |
long |
getNumBytesReceived() |
long |
getNumBytesSent() |
long |
getNumInternalMsgsReceived() |
long |
getNumMsgsReceived() |
long |
getNumMsgsSent() |
long |
getNumOOBMsgsReceived() |
int |
getNumRejectedMsgs() |
long |
getNumSingleMsgsSent() |
int |
getNumThreadsSpawned() |
MsgStats |
incrNumBatchesReceived(int d) |
MsgStats |
incrNumBatchesSent(int d) |
MsgStats |
incrNumBytesReceived(int d) |
MsgStats |
incrNumBytesSent(int d) |
MsgStats |
incrNumInternalMsgsReceived(int d) |
MsgStats |
incrNumMsgsReceived(int d) |
MsgStats |
incrNumMsgsSent(int d) |
MsgStats |
incrNumOOBMsgsReceived(int d) |
MsgStats |
incrNumRejectedMsgs(int d) |
MsgStats |
incrNumSingleMsgsSent(int d) |
MsgStats |
incrNumThreadsSpawned(int d) |
MsgStats |
reset() |
String |
toString() |
protected final LongAdder num_msgs_sent
protected final LongAdder num_msgs_received
protected final LongAdder num_single_msgs_sent
protected final LongAdder num_oob_msgs_received
protected final LongAdder num_internal_msgs_received
protected final LongAdder num_batches_sent
protected final LongAdder num_batches_received
protected final LongAdder num_bytes_sent
protected final LongAdder num_bytes_received
protected final AtomicInteger num_rejected_msgs
protected final AtomicInteger num_threads_spawned
public long getNumMsgsSent()
public MsgStats incrNumMsgsSent(int d)
public long getNumMsgsReceived()
public MsgStats incrNumMsgsReceived(int d)
public long getNumOOBMsgsReceived()
public MsgStats incrNumOOBMsgsReceived(int d)
public long getNumInternalMsgsReceived()
public MsgStats incrNumInternalMsgsReceived(int d)
public long getNumSingleMsgsSent()
public MsgStats incrNumSingleMsgsSent(int d)
public long getNumBatchesSent()
public MsgStats incrNumBatchesSent(int d)
public long getNumBatchesReceived()
public MsgStats incrNumBatchesReceived(int d)
public long getNumBytesSent()
public MsgStats incrNumBytesSent(int d)
public long getNumBytesReceived()
public MsgStats incrNumBytesReceived(int d)
public int getNumRejectedMsgs()
public MsgStats incrNumRejectedMsgs(int d)
public int getNumThreadsSpawned()
public MsgStats incrNumThreadsSpawned(int d)
public MsgStats reset()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.