consumer: don't stop the ticker if we time out

eapache · eapache · commit eae91468c242 · 2018-02-26T09:34:37.000-05:00
Now that we reuse a single ticker the whole time, this would probably lead to the consumer just kind of hanging and never resuming. Thanks to #1028 (comment) for catching this.
diff --git 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

Original file line number	Diff line number	Diff line change
`@@ -461,7 +461,6 @@ feederLoop:`
`461`	`461`	`child.messages <- msg`
`462`	`462`	`}`
`463`	`463`	`child.broker.input <- child`
`464`		`- expiryTicker.Stop()`
`465`	`464`	`continue feederLoop`
`466`	`465`	`} else {`
`467`	`466`	`// current message has not been sent, return to select`