|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cxf.ws.rm.soap.RetransmissionQueueImpl
public class RetransmissionQueueImpl
Nested Class Summary | |
---|---|
protected class |
RetransmissionQueueImpl.ResendCandidate
Represents a candidate for resend, i.e. |
static interface |
RetransmissionQueueImpl.Resender
Encapsulates actual resend logic (pluggable to facilitate unit testing) |
Field Summary |
---|
Fields inherited from interface org.apache.cxf.ws.rm.RetransmissionQueue |
---|
DEFAULT_BASE_RETRANSMISSION_INTERVAL, DEFAULT_EXPONENTIAL_BACKOFF |
Constructor Summary | |
---|---|
RetransmissionQueueImpl(RMManager m)
|
Method Summary | |
---|---|
void |
addUnacknowledged(Message message)
Accepts a new context for posible future retransmission. |
protected RetransmissionQueueImpl.ResendCandidate |
cacheUnacknowledged(Message message)
Accepts a new resend candidate. |
int |
countUnacknowledged(SourceSequence seq)
|
protected RetransmissionQueueImpl.ResendCandidate |
createResendCandidate(Message message)
|
protected JaxbAssertion<org.apache.cxf.ws.rm.policy.RMAssertion> |
getAssertion(AssertionInfo ai)
|
protected RetransmissionQueueImpl.Resender |
getDefaultResender()
Create default Resender logic. |
protected int |
getExponentialBackoff()
|
RMManager |
getManager()
|
protected java.util.List<RetransmissionQueueImpl.ResendCandidate> |
getSequenceCandidates(SourceSequence seq)
|
protected java.util.List<RetransmissionQueueImpl.ResendCandidate> |
getSequenceCandidates(java.lang.String key)
|
protected java.util.Map<java.lang.String,java.util.List<RetransmissionQueueImpl.ResendCandidate>> |
getUnacknowledged()
|
boolean |
isEmpty()
|
void |
purgeAcknowledged(SourceSequence seq)
Purge all candidates for the given sequence that have been acknowledged. |
protected void |
replaceResender(RetransmissionQueueImpl.Resender replacement)
Plug in replacement resend logic (facilitates unit testing). |
void |
setManager(RMManager m)
|
void |
start()
Initiate resends. |
void |
stop(SourceSequence seq)
Stops resending messages for the specified source sequence. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RetransmissionQueueImpl(RMManager m)
Method Detail |
---|
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 consideration
public 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 context
protected RetransmissionQueueImpl.ResendCandidate cacheUnacknowledged(Message message)
ctx
- the message context.
protected java.util.Map<java.lang.String,java.util.List<RetransmissionQueueImpl.ResendCandidate>> getUnacknowledged()
protected java.util.List<RetransmissionQueueImpl.ResendCandidate> getSequenceCandidates(SourceSequence seq)
seq
- the sequence under consideration
protected java.util.List<RetransmissionQueueImpl.ResendCandidate> getSequenceCandidates(java.lang.String key)
key
- the sequence identifier under consideration
protected final RetransmissionQueueImpl.Resender getDefaultResender()
protected void replaceResender(RetransmissionQueueImpl.Resender replacement)
replacement
- resend logicprotected JaxbAssertion<org.apache.cxf.ws.rm.policy.RMAssertion> getAssertion(AssertionInfo ai)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |