Package org.apache.cxf.ws.rm.soap
Class RedeliveryQueueImpl.RedeliverCandidate
- java.lang.Object
-
- org.apache.cxf.ws.rm.soap.RedeliveryQueueImpl.RedeliverCandidate
-
- All Implemented Interfaces:
Runnable
,RetryStatus
- Enclosing class:
- RedeliveryQueueImpl
protected class RedeliveryQueueImpl.RedeliverCandidate extends Object implements Runnable, RetryStatus
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
RedeliverCandidate(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 redelivery (although not successfully delivered).long
getBackoff()
int
getMaxRetries()
protected org.apache.cxf.message.Message
getMessage()
Date
getNext()
long
getNextInterval()
long
getNumber()
Date
getPrevious()
int
getRetries()
protected void
initiate()
Initiate redelivery asynchronsly.boolean
isPending()
boolean
isSuspended()
protected void
resolved()
the message has been delivered to the applicationprotected void
resume()
void
run()
protected void
schedule()
protected void
suspend()
-
-
-
Method Detail
-
initiate
protected void initiate()
Initiate redelivery asynchronsly.
-
getNumber
public long getNumber()
-
getNext
public Date getNext()
- Specified by:
getNext
in interfaceRetryStatus
- Returns:
- the next retry time
-
getPrevious
public Date getPrevious()
- Specified by:
getPrevious
in interfaceRetryStatus
- Returns:
- the previous retry time
-
getRetries
public int getRetries()
- Specified by:
getRetries
in interfaceRetryStatus
- Returns:
- the number of retries
-
getMaxRetries
public int getMaxRetries()
- Specified by:
getMaxRetries
in interfaceRetryStatus
- Returns:
- the max number of retries permitted
-
getNextInterval
public long getNextInterval()
- Specified by:
getNextInterval
in interfaceRetryStatus
- Returns:
- the nextInterval
-
getBackoff
public long getBackoff()
- Specified by:
getBackoff
in interfaceRetryStatus
- Returns:
- the backoff
-
isPending
public boolean isPending()
- Specified by:
isPending
in interfaceRetryStatus
- Returns:
- the pending
-
isSuspended
public boolean isSuspended()
- Specified by:
isSuspended
in interfaceRetryStatus
- Returns:
- the suspended
-
resolved
protected void resolved()
the message has been delivered to the application
-
cancel
protected void cancel()
Cancel further redelivery (although not successfully delivered).
-
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()
-
-