protected class RetransmissionQueueImpl.ResendCandidate extends Object implements Runnable, RetryStatus
| 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).
|
long |
getBackoff() |
int |
getMaxRetries() |
protected Message |
getMessage() |
Date |
getNext() |
long |
getNextInterval() |
long |
getNumber() |
Date |
getPrevious() |
int |
getRetries() |
protected void |
initiate(boolean requestAcknowledge)
Initiate resend asynchronsly.
|
boolean |
isPending() |
boolean |
isSuspended() |
protected void |
resolved()
ACK has been received for this candidate.
|
protected void |
resume() |
void |
run() |
protected void |
schedule() |
protected void |
suspend() |
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 resendpublic long getNumber()
public int getRetries()
getRetries in interface RetryStatuspublic int getMaxRetries()
getMaxRetries in interface RetryStatuspublic Date getNext()
getNext in interface RetryStatuspublic Date getPrevious()
getPrevious in interface RetryStatuspublic long getNextInterval()
getNextInterval in interface RetryStatuspublic long getBackoff()
getBackoff in interface RetryStatuspublic boolean isSuspended()
isSuspended in interface RetryStatuspublic boolean isPending()
isPending in interface RetryStatusprotected void resolved()
protected void cancel()
protected void suspend()
protected void resume()
protected Message getMessage()
protected void attempted()
protected final void schedule()
Apache CXF