Merge pull request #1036 from daedric/master

Avoid Ticker leak in case of slow consumers
IBM · Feb 6, 2018 · 38f3411 · 38f3411
2 parents f7466ea + cd0485e
commit 38f3411
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/consumer.go b/consumer.go
@@ -461,6 +461,7 @@ feederLoop:
 						child.messages <- msg
 					}
 					child.broker.input <- child
+					expiryTicker.Stop()
 					continue feederLoop
 				} else {
 					// current message has not been sent, return to select