protected class RetransmissionQueueImpl.ResendCandidate extends Object implements Runnable
Modifier | Constructor and Description |
---|---|
protected |
RetransmissionQueueImpl.ResendCandidate(Message m) |
Modifier and Type | Method and Description |
---|---|
protected void |
attempted()
A resend has been attempted.
|
protected void |
cancel()
Cancel further resend (although no ACK has been received).
|
protected Message |
getMessage() |
protected Date |
getNext() |
protected int |
getResends() |
protected void |
initiate(boolean requestAcknowledge)
Initiate resend asynchronsly.
|
protected boolean |
isPending() |
protected void |
resolved()
ACK has been received for this candidate.
|
void |
run() |
protected void |
schedule() |
protected RetransmissionQueueImpl.ResendCandidate(Message m)
ctx
- message context for the unacked messageprotected void initiate(boolean requestAcknowledge)
requestAcknowledge
- true if a AckRequest header is to be sent
with resendprotected int getResends()
protected Date getNext()
protected boolean isPending()
protected void resolved()
protected void cancel()
protected Message getMessage()
protected void attempted()
protected final void schedule()
Apache CXF