public class MessageCountingCallback extends Object implements MessageCallback
| Constructor and Description |
|---|
MessageCountingCallback() |
| Modifier and Type | Method and Description |
|---|---|
int |
getCountOutstanding()
Get the number of messages accepted for sending which have not yet been acknowledged.
|
void |
messageAccepted(String seqId,
long msgNum) |
void |
messageAcknowledged(String seqId,
long msgNum) |
boolean |
waitComplete(long timeout)
Wait for all accepted messages to be acknowledged.
|
public void messageAccepted(String seqId, long msgNum)
messageAccepted in interface MessageCallbackpublic void messageAcknowledged(String seqId, long msgNum)
messageAcknowledged in interface MessageCallbackpublic int getCountOutstanding()
public boolean waitComplete(long timeout)
timeout - maximum time to wait, in milliseconds (no timeout if 0)true if all accepted messages acknowledged, false if timed outApache CXF