File tree Expand file tree Collapse file tree 3 files changed +3
-7
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator Expand file tree Collapse file tree 3 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -6,7 +6,6 @@ public interface RetryConfiguration {
6
6
7
7
int DEFAULT_MAX_ATTEMPTS = 5 ;
8
8
long DEFAULT_INITIAL_INTERVAL = 2000L ;
9
-
10
9
double DEFAULT_MULTIPLIER = 1.5D ;
11
10
12
11
default int getMaxAttempts () {
Original file line number Diff line number Diff line change 3
3
import io .javaoperatorsdk .operator .api .config .RetryConfiguration ;
4
4
5
5
public class GenericRetry implements Retry {
6
-
7
- public static final int DEFAULT_MAX_ATTEMPTS = 5 ;
8
- public static final long DEFAULT_INITIAL_INTERVAL = 2000L ;
9
- public static final double DEFAULT_MULTIPLIER = 1.5D ;
10
-
11
6
private int maxAttempts = DEFAULT_MAX_ATTEMPTS ;
12
7
private long initialInterval = DEFAULT_INITIAL_INTERVAL ;
13
8
private double intervalMultiplier = DEFAULT_MULTIPLIER ;
Original file line number Diff line number Diff line change 1
1
package io .javaoperatorsdk .operator .processing .retry ;
2
2
3
- public interface Retry {
3
+ import io .javaoperatorsdk .operator .api .config .RetryConfiguration ;
4
+
5
+ public interface Retry extends RetryConfiguration {
4
6
5
7
RetryExecution initExecution ();
6
8
}
You can’t perform that action at this time.
0 commit comments