Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.apache.cxf.ws.rm.soap
Class RetransmissionQueueImpl.ResendCandidate

java.lang.Object
  extended by 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
protected RetransmissionQueueImpl.ResendCandidate(Message m)
           
 
Method Summary
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()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RetransmissionQueueImpl.ResendCandidate

protected RetransmissionQueueImpl.ResendCandidate(Message m)
Parameters:
ctx - message context for the unacked message
Method Detail

initiate

protected void initiate(boolean requestAcknowledge)
Initiate resend asynchronsly.

Parameters:
requestAcknowledge - true if a AckRequest header is to be sent with resend

run

public void run()
Specified by:
run in interface Runnable

getNumber

public long getNumber()

getRetries

public int getRetries()
Specified by:
getRetries in interface RetryStatus
Returns:
number of resend attempts

getMaxRetries

public int getMaxRetries()
Specified by:
getMaxRetries in interface RetryStatus
Returns:
number of max resend attempts

getNext

public Date getNext()
Specified by:
getNext in interface RetryStatus
Returns:
date of next resend

getPrevious

public Date getPrevious()
Specified by:
getPrevious in interface RetryStatus
Returns:
date of previous resend or null if no attempt is yet taken

getNextInterval

public long getNextInterval()
Specified by:
getNextInterval in interface RetryStatus
Returns:
the nextInterval

getBackoff

public long getBackoff()
Specified by:
getBackoff in interface RetryStatus
Returns:
the backoff

isSuspended

public boolean isSuspended()
Specified by:
isSuspended in interface RetryStatus
Returns:
the suspended

isPending

public boolean isPending()
Specified by:
isPending in interface RetryStatus
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 Message getMessage()
Returns:
associated message context

attempted

protected void attempted()
A resend has been attempted. Schedule the next attempt.

schedule

protected final void schedule()
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
Apache CXF API
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Apache CXF