|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.dispatch.DispatchStatistic
public class DispatchStatistic
Collecting data on how many messages / bytes are successfully delivered.
Field Summary | |
---|---|
private long |
currBytesRead
The number of bytes read from the currently incoming message |
private long |
currBytesWritten
The number of bytes written from the currently outgoing message |
private java.lang.String |
lastDeliveryException
Holds the last exception text for JMX. |
private long |
numBytesToRead
The size of the currently incoming message |
private long |
numBytesToWrite
The size of the currently outgoing message |
private long |
numConnect
|
private int |
numDeliveryExceptions
Count the exceptions occurred since startup. |
private long |
numDisconnect
|
private long |
numErase
|
private long |
numGet
|
private long |
numPublish
|
private long |
numSubscribe
|
private long |
numUnSubscribe
|
private long |
numUpdate
|
private long |
numUpdateOneway
|
private long |
overallBytesRead
Overall bytes received since startup |
private long |
overallBytesWritten
Overall bytes send since startup |
protected long |
pingRoundTripDelay
|
protected long |
roundTripDelay
|
private boolean |
stalled
|
Constructor Summary | |
---|---|
DispatchStatistic()
|
Method Summary | |
---|---|
void |
clearCurrentReads()
Used to clear current (ongoing) read operations. |
void |
clearCurrentWrites()
Used to clear current (ongoing) write operations. |
long |
getCurrBytesRead()
The number of bytes read from the currently incoming message |
long |
getCurrBytesWritten()
The number of bytes read from the currently outgoing message or response |
java.lang.String |
getLastDeliveryException()
Holds the last exception text for JMX. |
long |
getNumBytesToRead()
The size of the currently incoming message |
long |
getNumBytesToWrite()
The size of the currently outgoing message or response |
long |
getNumConnect()
How many connect requests sent. |
int |
getNumDeliveryExceptions()
Count the exceptions occurred since startup. |
long |
getNumDisconnect()
How many disconnect requests sent. |
long |
getNumErase()
How many erase requests sent. |
long |
getNumGet()
How many synchronous get requests sent. |
long |
getNumPublish()
How many messages where published. |
long |
getNumSubscribe()
How many subscribe requests sent. |
long |
getNumUnSubscribe()
How many unSubscribe requests sent. |
long |
getNumUpdate()
How many update where sent for this client, the sum of all session and subject queues of this clients. |
long |
getNumUpdateOneway()
How many update where sent for this client, the sum of all session and subject queues of this clients. |
long |
getOverallBytesRead()
Overall bytes received since startup |
long |
getOverallBytesWritten()
Overall bytes send since startup |
long |
getPingRoundTripDelay()
|
long |
getRoundTripDelay()
|
void |
incrNumConnect(long count)
Add count connect requests. |
void |
incrNumDeliveryExceptions(int count)
Count the exceptions occurred since startup. |
void |
incrNumDisconnect(long count)
Add count disconnect requests. |
void |
incrNumErase(long count)
Add count erase requests. |
void |
incrNumGet(long count)
Add count get requests. |
void |
incrNumPublish(long count)
Add count messages which where published |
void |
incrNumSubscribe(long count)
Add count subscribe requests. |
void |
incrNumUnSubscribe(long count)
Add count unSubscribe requests. |
void |
incrNumUpdate(long count)
Add count messages which where updated |
void |
incrNumUpdateOneway(long count)
Add count messages which where updated |
boolean |
isStalled()
|
boolean |
ongoingRead()
returns true if a read operation is ongoing |
boolean |
ongoingWrite()
returns true if a write operation is ongoing |
void |
progressRead(java.lang.String name,
long currBytesRead,
long numBytes)
Implements I_ProgressListener interface. |
void |
progressWrite(java.lang.String name,
long currBytesWritten,
long numBytes)
Implements I_ProgressListener interface. |
void |
setLastDeliveryException(java.lang.String lastDeliveryException)
Set the last exception text for JMX. |
void |
setPingRoundTripDelay(long pingRoundTripDelay)
|
void |
setRoundTripDelay(long roundTripDelay)
|
void |
setStalled(boolean stalled)
|
java.lang.String |
toXml(java.lang.String extraOffset)
Dump state of this object into a XML ASCII string. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private long numUpdate
private long numUpdateOneway
private long numPublish
private long numSubscribe
private long numUnSubscribe
private long numConnect
private long numErase
private long numGet
private long numDisconnect
private java.lang.String lastDeliveryException
private int numDeliveryExceptions
private long currBytesRead
private long numBytesToRead
private long overallBytesRead
private long currBytesWritten
private long numBytesToWrite
private long overallBytesWritten
protected long pingRoundTripDelay
protected long roundTripDelay
private boolean stalled
Constructor Detail |
---|
public DispatchStatistic()
Method Detail |
---|
public void progressRead(java.lang.String name, long currBytesRead, long numBytes)
progressRead
in interface I_ProgressListener
name
- A qualifying name about the incoming request, can be empty.currBytesRead
- The number of bytes received up to nownumBytes
- The overall number of bytespublic void progressWrite(java.lang.String name, long currBytesWritten, long numBytes)
progressWrite
in interface I_ProgressListener
name
- A qualifying name about the incoming request, can be empty.currBytesWritten
- The number of bytes send up to nownumBytes
- The overall number of bytespublic final long getCurrBytesRead()
public final long getNumBytesToRead()
public final long getOverallBytesRead()
public final long getCurrBytesWritten()
public final long getNumBytesToWrite()
public final long getOverallBytesWritten()
public final void incrNumUpdate(long count)
count
- The additional number of messagespublic final long getNumUpdate()
public final void incrNumUpdateOneway(long count)
count
- The additional number of messagespublic final long getNumUpdateOneway()
public final void incrNumPublish(long count)
count
- The additional number of messagespublic final long getNumPublish()
public final void incrNumSubscribe(long count)
count
- The additional number of subscribe requestspublic final long getNumSubscribe()
public final void incrNumUnSubscribe(long count)
count
- The additional number of unSubscribe requestspublic final long getNumUnSubscribe()
public final void incrNumErase(long count)
count
- The additional number of erase requestspublic final long getNumErase()
public final void incrNumGet(long count)
count
- The additional number of get equestspublic final long getNumGet()
public final void incrNumConnect(long count)
count
- The additional number of connect requestspublic final long getNumConnect()
public final void incrNumDisconnect(long count)
count
- The additional number of disconnect requestspublic final long getNumDisconnect()
public final java.lang.String getLastDeliveryException()
public final void setLastDeliveryException(java.lang.String lastDeliveryException)
public final void incrNumDeliveryExceptions(int count)
public final int getNumDeliveryExceptions()
public final java.lang.String toXml(java.lang.String extraOffset)
extraOffset
- indenting of tags for nice output
public long getPingRoundTripDelay()
public void setPingRoundTripDelay(long pingRoundTripDelay)
pingRoundTripDelay
- The pingRoundTripDelay to set.public long getRoundTripDelay()
public void setRoundTripDelay(long roundTripDelay)
roundTripDelay
- The roundTripDelay to set.public boolean ongoingWrite()
public boolean ongoingRead()
public void clearCurrentWrites()
I_ProgressListener
clearCurrentWrites
in interface I_ProgressListener
public void clearCurrentReads()
I_ProgressListener
clearCurrentReads
in interface I_ProgressListener
public boolean isStalled()
public void setStalled(boolean stalled)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |