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 and Description
protected	ResendCandidate(Message m)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResendCandidate

protected ResendCandidate(Message m)

Parameters:

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