Avoid Ticker leak in case of slow consumer

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