org.jacorb.notification.engine
Class TaskProcessorRetryStrategy

java.lang.Object
  extended byorg.jacorb.notification.engine.AbstractRetryStrategy
      extended byorg.jacorb.notification.engine.TaskProcessorRetryStrategy
All Implemented Interfaces:
org.picocontainer.Disposable, Disposable, PushTaskExecutor.PushTask, RetryStrategy

public class TaskProcessorRetryStrategy
extends AbstractRetryStrategy
implements PushTaskExecutor.PushTask

Version:
$Id: TaskProcessorRetryStrategy.java,v 1.15 2006/03/07 19:23:47 alphonse.bendt Exp $
Author:
Alphonse Bendt

Field Summary
 java.lang.Runnable retryPushOperation_
          retry the failed operation. schedule the retry for delivery.
 
Fields inherited from class org.jacorb.notification.engine.AbstractRetryStrategy
logger_, pushOperation_, pushSupplier_
 
Constructor Summary
TaskProcessorRetryStrategy(IProxyPushSupplier pushSupplier, PushOperation pushOperation, TaskProcessor taskProcessor, long backoutInterval)
           
 
Method Summary
 void cancel()
           
 void doPush()
           
protected  long getTimeToWait()
           
protected  void retryInternal()
           
 
Methods inherited from class org.jacorb.notification.engine.AbstractRetryStrategy
dispose, isFatalException, isRetryAllowed, remoteExceptionOccured, retry
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

retryPushOperation_

public final java.lang.Runnable retryPushOperation_
retry the failed operation. schedule the retry for delivery.

Constructor Detail

TaskProcessorRetryStrategy

public TaskProcessorRetryStrategy(IProxyPushSupplier pushSupplier,
                                  PushOperation pushOperation,
                                  TaskProcessor taskProcessor,
                                  long backoutInterval)
Method Detail

getTimeToWait

protected long getTimeToWait()
Specified by:
getTimeToWait in class AbstractRetryStrategy

retryInternal

protected void retryInternal()
                      throws RetryException
Specified by:
retryInternal in class AbstractRetryStrategy
Throws:
RetryException

doPush

public void doPush()
Specified by:
doPush in interface PushTaskExecutor.PushTask

cancel

public void cancel()
Specified by:
cancel in interface PushTaskExecutor.PushTask