package foam.nanos.ruler;

import foam.core.ContextAgent;
import foam.core.X;
import foam.nanos.logger.Logger;

import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;

public class RetryManager {
  protected final int      maxRetry_;
  protected final int      retryDelay_;
  protected final String   description_;
  protected CountDownLatch latch_;
  protected Exception      exception_;

  class Retry {
    final X            x_;
    final ContextAgent agent_;
    AtomicInteger      retryCount_ = new AtomicInteger(0);

    public Retry(X x, ContextAgent agent) {
      x_     = x;
      agent_ = agent;
    }

    public void start() {
      if ( retryCount_.getAndIncrement() < maxRetry_ ) {
        retry();
      } else {
        ((Logger) x_.get("logger")).error(
          "RetryManager(" + description_ + ") max retry reached.", exception_);
      }
    }

    private void retry() {
      new Timer().schedule(new TimerTask() {
        @Override
        public void run() {
          try {
            agent_.execute(x_);
            while ( latch_.getCount() > 0 ) {
              latch_.countDown();
            }
          } catch (Exception ex) {
            exception_ = ex;
            start();
            latch_.countDown();
          }
        }
      }, retryDelay_);
    }
  }

  public RetryManager(String description) {
    this(5, 10000, description);
  }

  public RetryManager(int maxRetry, int retryDelay, String description) {
    maxRetry_ = maxRetry;
    retryDelay_ = retryDelay;
    description_ = description;
    latch_ = new CountDownLatch(maxRetry);
  }

  public void submit(X x, ContextAgent agent) {
    new Retry(x, agent).start();
    try {
      latch_.await();
    } catch (InterruptedException e) { /*ignored*/ }
  }
}

@@ -917,17 +917,37 @@
 try 
-reached.%22
+has been reached.%22%0A          
 , ex

Fix wording