Package org.apache.cxf.ws.rm.soap
Class RetransmissionQueueImpl.ResendCandidate
- java.lang.Object
-
- org.apache.cxf.ws.rm.soap.RetransmissionQueueImpl.ResendCandidate
-
- All Implemented Interfaces:
Runnable
,RetryStatus
- Enclosing class:
- RetransmissionQueueImpl
protected class RetransmissionQueueImpl.ResendCandidate extends Object implements Runnable, RetryStatus
Represents a candidate for resend, i.e. an unacked outgoing message.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
ResendCandidate(org.apache.cxf.message.Message m)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 org.apache.cxf.message.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()
-
-
-
Method Detail
-
initiate
protected void initiate(boolean requestAcknowledge)
Initiate resend asynchronsly.- Parameters:
requestAcknowledge
- true if a AckRequest header is to be sent with resend
-
getNumber
public long getNumber()
-
getRetries
public int getRetries()
- Specified by:
getRetries
in interfaceRetryStatus
- Returns:
- number of resend attempts
-
getMaxRetries
public int getMaxRetries()
- Specified by:
getMaxRetries
in interfaceRetryStatus
- Returns:
- number of max resend attempts
-
getNext
public Date getNext()
- Specified by:
getNext
in interfaceRetryStatus
- Returns:
- date of next resend
-
getPrevious
public Date getPrevious()
- Specified by:
getPrevious
in interfaceRetryStatus
- Returns:
- date of previous resend or null if no attempt is yet taken
-
getNextInterval
public long getNextInterval()
- Specified by:
getNextInterval
in interfaceRetryStatus
- Returns:
- the nextInterval
-
getBackoff
public long getBackoff()
- Specified by:
getBackoff
in interfaceRetryStatus
- Returns:
- the backoff
-
isSuspended
public boolean isSuspended()
- Specified by:
isSuspended
in interfaceRetryStatus
- Returns:
- the suspended
-
isPending
public boolean isPending()
- Specified by:
isPending
in interfaceRetryStatus
- Returns:
- if resend attempt is pending
-
resolved
protected void resolved()
ACK has been received for this candidate.
-
cancel
protected void cancel()
Cancel further resend (although no ACK has been received).
-
suspend
protected void suspend()
-
resume
protected void resume()
-
getMessage
protected org.apache.cxf.message.Message getMessage()
- Returns:
- associated message context
-
attempted
protected void attempted()
A resend has been attempted. Schedule the next attempt.
-
schedule
protected final void schedule()
-
-