diff --git a/consumer.go b/consumer.go
index e9ccad625..be4e6d4a3 100644
--- a/consumer.go
+++ b/consumer.go
@@ -461,7 +461,6 @@ feederLoop:
 						child.messages <- msg
 					}
 					child.broker.input <- child
-					expiryTicker.Stop()
 					continue feederLoop
 				} else {
 					// current message has not been sent, return to select