org.apache.cxf.ws.rm
Interface RetransmissionQueue

All Known Implementing Classes:

RetransmissionQueueImpl

public interface RetransmissionQueue

Field Summary

static String	DEFAULT_BASE_RETRANSMISSION_INTERVAL
static int	DEFAULT_EXPONENTIAL_BACKOFF

Method Summary

void	addUnacknowledged(Message message) Accepts a new context for posible future retransmission.
int	countUnacknowledged(SourceSequence seq)
boolean	isEmpty()
void	purgeAcknowledged(SourceSequence seq) Purge all candidates for the given sequence that have been acknowledged.
void	start() Initiate resends.
void	stop(SourceSequence seq) Stops retransmission queue.

Field Detail

DEFAULT_BASE_RETRANSMISSION_INTERVAL

static final String DEFAULT_BASE_RETRANSMISSION_INTERVAL

See Also:

Constant Field Values

DEFAULT_EXPONENTIAL_BACKOFF

static final int DEFAULT_EXPONENTIAL_BACKOFF

See Also:

Constant Field Values

Method Detail

countUnacknowledged

int countUnacknowledged(SourceSequence seq)

Parameters:

seq - the sequence under consideration

Returns:

the number of unacknowledged messages for that sequence

isEmpty

boolean isEmpty()

Returns:

true if there are no unacknowledged messages in the queue

addUnacknowledged

void addUnacknowledged(Message message)

Accepts a new context for posible future retransmission.

Parameters:

ctx - the message context.

purgeAcknowledged

void purgeAcknowledged(SourceSequence seq)

Purge all candidates for the given sequence that have been acknowledged.

Parameters:

seq - the sequence object.

start

void start()

Initiate resends.

stop

void stop(SourceSequence seq)

Stops retransmission queue.