org.apache.cxf.ws.rm

Interface RedeliveryQueue

All Known Implementing Classes:

RedeliveryQueueImpl

public interface RedeliveryQueue

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_BASE_REDELIVERY_INTERVAL
static int	DEFAULT_EXPONENTIAL_BACKOFF

Method Summary

Modifier and Type	Method and Description
void	addUndelivered(Message message) Accepts a failed message for possible future redelivery.
int	countUndelivered()
int	countUndelivered(DestinationSequence seq)
RetryStatus	getRedeliveryStatus(DestinationSequence seq, long num) Returns the retransmission status for the specified message.
Map<Long,RetryStatus>	getRedeliveryStatuses(DestinationSequence seq) Return the retransmission status of all the messages assigned to the sequence.
List<Long>	getUndeliveredMessageNumbers(DestinationSequence seq)
boolean	isEmpty()
void	purgeAll(DestinationSequence seq) Purge all candiates for the given sequence.
void	resume(DestinationSequence seq) Resumes the redelivery attempts for the specified sequence
void	start() Initiate resends.
void	stop(DestinationSequence seq) Stops redelivery queue.
void	suspend(DestinationSequence seq) Suspends the redelivery attempts for the specified sequence

Field Detail

DEFAULT_BASE_REDELIVERY_INTERVAL

static final String DEFAULT_BASE_REDELIVERY_INTERVAL

See Also:

Constant Field Values

DEFAULT_EXPONENTIAL_BACKOFF

static final int DEFAULT_EXPONENTIAL_BACKOFF

See Also:

Constant Field Values

Method Detail

countUndelivered

int countUndelivered(DestinationSequence seq)

Parameters:

seq - the sequence under consideration

Returns:

the number of unacknowledged messages for that sequence

countUndelivered

int countUndelivered()

Returns:

the total number of undelivered messages in this queue

isEmpty

boolean isEmpty()

Returns:

true if there are no unacknowledged messages in the queue

addUndelivered

void addUndelivered(Message message)

Accepts a failed message for possible future redelivery.

Parameters:

message - the message context.

purgeAll

void purgeAll(DestinationSequence seq)

Purge all candiates for the given sequence.

Parameters:

seq - the sequence object

getUndeliveredMessageNumbers

List<Long> getUndeliveredMessageNumbers(DestinationSequence seq)

Parameters:

seq -

Returns:

getRedeliveryStatus

RetryStatus getRedeliveryStatus(DestinationSequence seq,
                                long num)

Returns the retransmission status for the specified message.

Parameters:

seq -

num -

Returns:

getRedeliveryStatuses

Map<Long,RetryStatus> getRedeliveryStatuses(DestinationSequence seq)

Return the retransmission status of all the messages assigned to the sequence.

Parameters:

seq -

Returns:

start

void start()

Initiate resends.

stop

void stop(DestinationSequence seq)

Stops redelivery queue.

Parameters:

seq -

suspend

void suspend(DestinationSequence seq)

Suspends the redelivery attempts for the specified sequence

Parameters:

seq -

resume

void resume(DestinationSequence seq)

Resumes the redelivery attempts for the specified sequence

Parameters:

seq -