Merge pull request #1814 from adioss/resetFail

Backoff is not reset correctly after a correct ack is sent
elastic · Jun 8, 2016 · 43b4197 · 43b4197
2 parents 664f273 + 9c7dcc2
commit 43b4197
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go
@@ -132,6 +132,7 @@ func (s *SingleConnectionMode) publish(
 			goto sendFail
 		}
 
+		backoffCount = 0
 		debug("send completed")
 		outputs.SignalCompleted(signaler)
 		return nil
@@ -141,6 +142,7 @@ func (s *SingleConnectionMode) publish(
 		if resetFail {
 			debug("reset fails")
 			fails = 0
+			backoffCount = 0
 		}
 
 		if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) {