public class TaskProcessorRetryStrategy extends AbstractRetryStrategy implements PushTaskExecutor.PushTask
Modifier and Type | Field and Description |
---|---|
java.lang.Runnable |
retryPushOperation_
retry the failed operation.
|
logger_, pushOperation_, pushSupplier_
Constructor and Description |
---|
TaskProcessorRetryStrategy(IProxyPushSupplier pushSupplier,
PushOperation pushOperation,
TaskProcessor taskProcessor,
long backoutInterval) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
doPush() |
protected long |
getTimeToWait() |
protected void |
retryInternal() |
dispose, isFatalException, isRetryAllowed, remoteExceptionOccured, retry
public final java.lang.Runnable retryPushOperation_
public TaskProcessorRetryStrategy(IProxyPushSupplier pushSupplier, PushOperation pushOperation, TaskProcessor taskProcessor, long backoutInterval)
protected long getTimeToWait()
getTimeToWait
in class AbstractRetryStrategy
protected void retryInternal() throws RetryException
retryInternal
in class AbstractRetryStrategy
RetryException
public void doPush()
doPush
in interface PushTaskExecutor.PushTask
public void cancel()
cancel
in interface PushTaskExecutor.PushTask