Merge pull request #38 from spotify/delays

Add setter for RetryUtil in scheduler builder
spotify · Jan 12, 2017 · 3dd7949 · 3dd7949
2 parents dc5fd68 + 4ef4e24
commit 3dd7949
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/styx-scheduler-service/src/main/java/com/spotify/styx/StyxScheduler.java b/styx-scheduler-service/src/main/java/com/spotify/styx/StyxScheduler.java
@@ -122,7 +122,7 @@ public class StyxScheduler implements AppInit {
   public static final int SCHEDULER_TICK_INTERVAL_SECONDS = 2;
   public static final int TRIGGER_MANAGER_TICK_INTERVAL_SECONDS = 1;
   public static final Duration DEFAULT_RETRY_BASE_DELAY = Duration.ofMinutes(3);
-  public static final int DEFAULT_RETRY_MAX_EXPONENT = 6;
+  public static final int DEFAULT_RETRY_MAX_EXPONENT = 4;
   public static final Duration DEFAULT_RETRY_BASE_DELAY_BT = Duration.ofSeconds(1);
   public static final RetryUtil DEFAULT_RETRY_UTIL =
       new RetryUtil(DEFAULT_RETRY_BASE_DELAY, DEFAULT_RETRY_MAX_EXPONENT);
@@ -198,6 +198,11 @@ public Builder setPublisherFactory(PublisherFactory publisherFactory) {
       return this;
     }
 
+    public Builder setRetryUtil(RetryUtil retryUtil) {
+      this.retryUtil = retryUtil;
+      return this;
+    }
+
     public StyxScheduler build() {
       return new StyxScheduler(
           time,