org.apache.cxf.ws.rm.soap

Class RedeliveryQueueImpl

java.lang.Object

org.apache.cxf.ws.rm.soap.RedeliveryQueueImpl

All Implemented Interfaces:

RedeliveryQueue

public class RedeliveryQueueImpl
extends Object
implements RedeliveryQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	RedeliveryQueueImpl.RedeliverCandidate

Field Summary

Fields inherited from interface org.apache.cxf.ws.rm.RedeliveryQueue

DEFAULT_BASE_REDELIVERY_INTERVAL, DEFAULT_EXPONENTIAL_BACKOFF

Constructor Summary

Constructors

Constructor and Description
RedeliveryQueueImpl(RMManager m)

Method Summary

Modifier and Type	Method and Description
void	addUndelivered(Message message) Accepts a failed message for possible future redelivery.
protected RedeliveryQueueImpl.RedeliverCandidate	cacheUndelivered(Message message) Accepts a new resend candidate.
int	countUndelivered()
int	countUndelivered(DestinationSequence seq)
RMManager	getManager()
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.
protected List<RedeliveryQueueImpl.RedeliverCandidate>	getSequenceCandidates(DestinationSequence seq)
protected List<RedeliveryQueueImpl.RedeliverCandidate>	getSequenceCandidates(String key)
protected Map<String,List<RedeliveryQueueImpl.RedeliverCandidate>>	getUndelivered()
List<Long>	getUndeliveredMessageNumbers(DestinationSequence seq)
boolean	isEmpty()
protected boolean	isSequenceSuspended(String key)
void	purgeAll(DestinationSequence seq) Purge all candiates for the given sequence.
protected void	purgeDelivered(RedeliveryQueueImpl.RedeliverCandidate candidate)
void	resume(DestinationSequence seq) Resumes the redelivery attempts for the specified sequence
void	setManager(RMManager m)
void	start() Initiate resends.
void	stop(DestinationSequence seq) Stops redelivery queue.
void	suspend(DestinationSequence seq) Suspends the redelivery attempts for the specified sequence

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedeliveryQueueImpl

public RedeliveryQueueImpl(RMManager m)

Method Detail

getManager

public RMManager getManager()

setManager

public void setManager(RMManager m)

addUndelivered

public void addUndelivered(Message message)

Description copied from interface: RedeliveryQueue

Accepts a failed message for possible future redelivery.

Specified by:

addUndelivered in interface RedeliveryQueue

Parameters:

message - the message context.

countUndelivered

public int countUndelivered(DestinationSequence seq)

Specified by:

countUndelivered in interface RedeliveryQueue

Parameters:

seq - the sequence under consideration

Returns:

the number of undelivered messages for that sequence

countUndelivered

public int countUndelivered()

Specified by:

countUndelivered in interface RedeliveryQueue

Returns:

the total number of undelivered messages in this queue

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface RedeliveryQueue

Returns:

true if there are no unacknowledged messages in the queue

purgeAll

public void purgeAll(DestinationSequence seq)

Description copied from interface: RedeliveryQueue

Purge all candiates for the given sequence.

Specified by:

purgeAll in interface RedeliveryQueue

Parameters:

seq - the sequence object

getUndeliveredMessageNumbers

public List<Long> getUndeliveredMessageNumbers(DestinationSequence seq)

Specified by:

getUndeliveredMessageNumbers in interface RedeliveryQueue

Returns:

getSequenceCandidates

protected List<RedeliveryQueueImpl.RedeliverCandidate> getSequenceCandidates(DestinationSequence seq)

Parameters:

seq - the sequence under consideration

Returns:

the list of resend candidates for that sequence

getSequenceCandidates

protected List<RedeliveryQueueImpl.RedeliverCandidate> getSequenceCandidates(String key)

Parameters:

key - the sequence identifier under consideration

Returns:

the list of resend candidates for that sequence

isSequenceSuspended

protected boolean isSequenceSuspended(String key)

Parameters:

key - the sequence identifier under consideration

Returns:

true if the sequence is currently suspended; false otherwise

getRedeliveryStatus

public RetryStatus getRedeliveryStatus(DestinationSequence seq,
                                       long num)

Description copied from interface: RedeliveryQueue

Returns the retransmission status for the specified message.

Specified by:

getRedeliveryStatus in interface RedeliveryQueue

Returns:

getRedeliveryStatuses

public Map<Long,RetryStatus> getRedeliveryStatuses(DestinationSequence seq)

Description copied from interface: RedeliveryQueue

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

Specified by:

getRedeliveryStatuses in interface RedeliveryQueue

Returns:

start

public void start()

Description copied from interface: RedeliveryQueue

Initiate resends.

Specified by:

start in interface RedeliveryQueue

stop

public void stop(DestinationSequence seq)

Description copied from interface: RedeliveryQueue

Stops redelivery queue.

Specified by:

stop in interface RedeliveryQueue

suspend

public void suspend(DestinationSequence seq)

Description copied from interface: RedeliveryQueue

Suspends the redelivery attempts for the specified sequence

Specified by:

suspend in interface RedeliveryQueue

resume

public void resume(DestinationSequence seq)

Description copied from interface: RedeliveryQueue

Resumes the redelivery attempts for the specified sequence

Specified by:

resume in interface RedeliveryQueue

cacheUndelivered

protected RedeliveryQueueImpl.RedeliverCandidate cacheUndelivered(Message message)

Accepts a new resend candidate.

Parameters:

ctx - the message context.

Returns:

ResendCandidate

purgeDelivered

protected void purgeDelivered(RedeliveryQueueImpl.RedeliverCandidate candidate)

getUndelivered

protected Map<String,List<RedeliveryQueueImpl.RedeliverCandidate>> getUndelivered()

Returns:

a map relating sequence ID to a lists of un-acknowledged messages for that sequence