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

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

All Implemented Interfaces:

Runnable

Enclosing class:

RetransmissionQueueImpl

protected class RetransmissionQueueImpl.ResendCandidate
extends Object
implements Runnable

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).
protected Message	getMessage()
protected Date	getNext()
protected int	getResends()
protected void	initiate(boolean requestAcknowledge) Initiate resend asynchronsly.
protected boolean	isPending()
protected void	resolved() ACK has been received for this candidate.
void	run()
protected void	schedule()

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

protected int getResends()

Returns:

number of resend attempts

getNext

protected Date getNext()

Returns:

date of next resend

isPending

protected boolean isPending()

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

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