Reset backoffCount after correct ACK received

leweafan · Jun 3, 2016 · 9248d0f · 9248d0f
1 parent 870fba3
commit 9248d0f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/libbeat/outputs/mode/single.go b/libbeat/outputs/mode/single.go
@@ -141,6 +141,7 @@ func (s *SingleConnectionMode) publish(
 		if resetFail {
 			debug("reset fails")
 			fails = 0
+			backoffCount = 0
 		}
 
 		if !guaranteed && (s.maxAttempts > 0 && fails == s.maxAttempts) {