public class RetransmissionQueueImpl extends Object implements RetransmissionQueue
Modifier and Type | Class and Description |
---|---|
protected class |
RetransmissionQueueImpl.ResendCandidate
Represents a candidate for resend, i.e.
|
static interface |
RetransmissionQueueImpl.Resender
Encapsulates actual resend logic (pluggable to facilitate unit testing)
|
DEFAULT_BASE_RETRANSMISSION_INTERVAL, DEFAULT_EXPONENTIAL_BACKOFF
Constructor and Description |
---|
RetransmissionQueueImpl(RMManager m) |
public RetransmissionQueueImpl(RMManager m)
public RMManager getManager()
public void setManager(RMManager m)
public void addUnacknowledged(Message message)
RetransmissionQueue
addUnacknowledged
in interface RetransmissionQueue
public int countUnacknowledged(SourceSequence seq)
countUnacknowledged
in interface RetransmissionQueue
seq
- the sequence under considerationpublic boolean isEmpty()
isEmpty
in interface RetransmissionQueue
public void purgeAcknowledged(SourceSequence seq)
purgeAcknowledged
in interface RetransmissionQueue
seq
- the sequence object.public void start()
start
in interface RetransmissionQueue
public void stop(SourceSequence seq)
stop
in interface RetransmissionQueue
protected int getExponentialBackoff()
protected RetransmissionQueueImpl.ResendCandidate createResendCandidate(Message message)
message
- the message contextprotected RetransmissionQueueImpl.ResendCandidate cacheUnacknowledged(Message message)
ctx
- the message context.protected Map<String,List<RetransmissionQueueImpl.ResendCandidate>> getUnacknowledged()
protected List<RetransmissionQueueImpl.ResendCandidate> getSequenceCandidates(SourceSequence seq)
seq
- the sequence under considerationprotected List<RetransmissionQueueImpl.ResendCandidate> getSequenceCandidates(String key)
key
- the sequence identifier under considerationprotected final RetransmissionQueueImpl.Resender getDefaultResender()
protected void replaceResender(RetransmissionQueueImpl.Resender replacement)
replacement
- resend logicprotected JaxbAssertion<RMAssertion> getAssertion(AssertionInfo ai)
Apache CXF