public final class RetryingDeliverer extends Object implements Deliverer
| Modifier and Type | Class and Description |
|---|---|
static interface |
RetryingDeliverer.PauseCalculator
Calculates time of subsequent pauses between delivery attempts.
|
| Constructor and Description |
|---|
RetryingDeliverer(Deliverer worker,
int timeout,
int pause,
boolean linear)
Creates retrying deliverer with predefined retry strategy.
|
RetryingDeliverer(Deliverer worker,
int timeout,
RetryingDeliverer.PauseCalculator strategy)
Creates retrying deliverer with custom retry strategy.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
deliver(org.apache.abdera.model.Element element)
Delivers ATOM element.
|
String |
getEndpointAddress()
Returns the address of the remote endpoint this deliverer send elements to
|
public RetryingDeliverer(Deliverer worker, int timeout, int pause, boolean linear)
worker - real deliverer used to push data out.timeout - maximum time range (in seconds) that retrial is continued; time spent on delivery call
is included. No timeout (infinite loop) if set to zero.pause - time of pause (in seconds) greater than zero.linear - if true linear strategy (each time pause same amount of time), exponential otherwise
(each next time pause time doubles).public RetryingDeliverer(Deliverer worker, int timeout, RetryingDeliverer.PauseCalculator strategy)
worker - real deliverer used to push data out.timeout - maximum time range (in seconds) that retrial is continued; time spent on delivery call
is included. No timeout (infinite loop) if set to zero.strategy - custom retry pausing strategy.public boolean deliver(org.apache.abdera.model.Element element)
throws InterruptedException
Delivererdeliver in interface Delivererelement - element to deliver.InterruptedExceptionpublic String getEndpointAddress()
DeliverergetEndpointAddress in interface DelivererApache CXF