fluent
diff --git a/‎src/main/java/org/fluentd/logger/sender/ConstantDelayReconnector.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/ConstantDelayReconnector.java
+1-1Lines changed: 1 addition & 1 deletion b/‎src/main/java/org/fluentd/logger/sender/ConstantDelayReconnector.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/ConstantDelayReconnector.java
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎src/main/java/org/fluentd/logger/sender/ExponentialDelayReconnector.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/ExponentialDelayReconnector.java
+3-2Lines changed: 3 additions & 2 deletions b/‎src/main/java/org/fluentd/logger/sender/ExponentialDelayReconnector.java
Copy file name to clipboardExpand all lines: src/main/java/org/fluentd/logger/sender/ExponentialDelayReconnector.java
+3-2Lines changed: 3 additions & 2 deletions
@@ -7,7 +7,7 @@
 import java.util.LinkedList;
 
 /**
- * Calculate exponential delay for reconnecting
+ * Handles constant delay for reconnecting. The default delay is 50 ms.
  */
 public class ConstantDelayReconnector implements Reconnector {
     private static final Logger LOG = LoggerFactory.getLogger(ConstantDelayReconnector.class);
 
@@ -3,7 +3,8 @@
 import java.util.LinkedList;
 
 /**
- * Calcurate exponential delay for reconnecting
+ * Calculates exponential delay for reconnecting. The start delay is 50ms and exponentionally grows to max 60 seconds in
+ * function of the number of connection errors.
  */
 public class ExponentialDelayReconnector implements Reconnector {
 
@@ -61,6 +62,6 @@ public boolean enableReconnection(long timestamp) {
             suppressMillis = waitMaxMillis;
         }
 
-        return (timestamp - errorHistory.getLast()) > suppressMillis;
+        return (timestamp - errorHistory.getLast()) >= suppressMillis;
     }
 }
Original file line number	Diff line number	Diff line change
`@@ -3,7 +3,8 @@`
`3`	`3`	`import java.util.LinkedList;`
`4`	`4`
`5`	`5`	`/**`
`6`		`- * Calcurate exponential delay for reconnecting`
	`6`	`+ * Calculates exponential delay for reconnecting. The start delay is 50ms and exponentionally grows to max 60 seconds in`
	`7`	`+ * function of the number of connection errors.`
`7`	`8`	`*/`
`8`	`9`	`public class ExponentialDelayReconnector implements Reconnector {`
`9`	`10`
`@@ -61,6 +62,6 @@ public boolean enableReconnection(long timestamp) {`
`61`	`62`	`suppressMillis = waitMaxMillis;`
`62`	`63`	`}`
`63`	`64`
`64`		`- return (timestamp - errorHistory.getLast()) > suppressMillis;`
	`65`	`+ return (timestamp - errorHistory.getLast()) >= suppressMillis;`
`65`	`66`	`}`
`66`	`67`	`}`