org.jacorb.notification.engine
Class RetryStrategy

java.lang.Object
  extended by org.jacorb.notification.engine.RetryStrategy
All Implemented Interfaces:
Disposable
Direct Known Subclasses:
TaskProcessorRetryStrategy, WaitRetryStrategy

public abstract class RetryStrategy
extends java.lang.Object
implements Disposable

Version:
$Id: RetryStrategy.java,v 1.3 2004/05/06 12:39:59 nicolas Exp $
Author:
Alphonse Bendt

Field Summary
protected  MessageConsumer messageConsumer_
           
protected  PushOperation pushOperation_
           
 
Constructor Summary
RetryStrategy(MessageConsumer mc, PushOperation operation)
           
 
Method Summary
 void dispose()
          Dispose this Object.
protected abstract  long getTimeToWait()
           
static boolean isFatalException(java.lang.Throwable error)
           
 void remoteExceptionOccured(java.lang.Throwable error)
           
abstract  void retry()
           
 boolean shouldRetry()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

pushOperation_

protected PushOperation pushOperation_

messageConsumer_

protected MessageConsumer messageConsumer_
Constructor Detail

RetryStrategy

public RetryStrategy(MessageConsumer mc,
                     PushOperation operation)
Method Detail

dispose

public void dispose()
Description copied from interface: Disposable
Dispose this Object. Free all associated Ressources allocated by this Object. The Object may not be used after a call to dispose.

Specified by:
dispose in interface Disposable

shouldRetry

public boolean shouldRetry()

remoteExceptionOccured

public void remoteExceptionOccured(java.lang.Throwable error)
                            throws RetryException
Throws:
RetryException

isFatalException

public static boolean isFatalException(java.lang.Throwable error)

getTimeToWait

protected abstract long getTimeToWait()

retry

public abstract void retry()
                    throws RetryException
Throws:
RetryException