diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/retry/GenericRetry.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/retry/GenericRetry.java index 36972f0ddd..5ee016b34f 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/retry/GenericRetry.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/retry/GenericRetry.java @@ -90,6 +90,10 @@ public GenericRetry setMaxInterval(long maxInterval) { return this; } + public GenericRetry setMaxInterval(Duration maxInterval) { + return setMaxInterval(maxInterval.toMillis()); + } + public GenericRetry withoutMaxInterval() { this.maxInterval = -1; return this;