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

java.lang.Object
  org.apache.cxf.ws.rm.soap.RetransmissionQueueImpl.ResendCandidate

All Implemented Interfaces:

Runnable, RetransmissionStatus

Enclosing class:

RetransmissionQueueImpl

protected class RetransmissionQueueImpl.ResendCandidate
extends Object
implements Runnable, RetransmissionStatus

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()
protected Message	getMessage()
Date	getNext()
long	getNextInterval()
Date	getPrevious()
int	getResends()
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

getResends

public int getResends()

Specified by:

getResends in interface RetransmissionStatus

Returns:

number of resend attempts

getNext

public Date getNext()

Specified by:

getNext in interface RetransmissionStatus

Returns:

date of next resend

getPrevious

public Date getPrevious()

Specified by:

getPrevious in interface RetransmissionStatus

Returns:

date of previous resend or null if no attempt is yet taken

getNextInterval

public long getNextInterval()

Specified by:

getNextInterval in interface RetransmissionStatus

Returns:

the nextInterval

getBackoff

public long getBackoff()

Specified by:

getBackoff in interface RetransmissionStatus

Returns:

the backoff

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface RetransmissionStatus

Returns:

the suspended

isPending

public boolean isPending()

Specified by:

isPending in interface RetransmissionStatus

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()