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.

MessageCountingCallback

public MessageCountingCallback()

messageAccepted

public void messageAccepted(String seqId,
                            long msgNum)

Specified by:

messageAccepted in interface MessageCallback

messageAcknowledged

public void messageAcknowledged(String seqId,
                                long msgNum)

Specified by:

messageAcknowledged in interface MessageCallback

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