Package org.apache.cxf.ws.rm
Class MessageCountingCallback
- java.lang.Object
-
- org.apache.cxf.ws.rm.MessageCountingCallback
-
- All Implemented Interfaces:
MessageCallback
public class MessageCountingCallback extends Object implements MessageCallback
Implementation just counts the number of messages accepted for sending and the number acknowledged, allows checking / waiting for completion.
-
-
Constructor Summary
Constructors Constructor Description MessageCountingCallback()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
Method Detail
-
messageAccepted
public void messageAccepted(String seqId, long msgNum)
- Specified by:
messageAccepted
in interfaceMessageCallback
-
messageAcknowledged
public void messageAcknowledged(String seqId, long msgNum)
- Specified by:
messageAcknowledged
in interfaceMessageCallback
-
getCountOutstanding
public int getCountOutstanding()
Get the number of messages accepted for sending which have not yet been acknowledged.- Returns:
- count
-
waitComplete
public boolean waitComplete(long timeout)
Wait for all accepted messages to be acknowledged.- Parameters:
timeout
- maximum time to wait, in milliseconds (no timeout if 0)- Returns:
true
if all accepted messages acknowledged,false
if timed out
-
-