Skip to content
Permalink
Browse files

refactor: remove extra timeout param (#67)

Change-Id: I9d5d544808a6f739d79776a4f154d7caceaa133c

remove extra timeout param on UnackedMessageTracker#handlerCmd
  • Loading branch information...
xujianhai666 authored and wolfstudy committed Oct 8, 2019
1 parent 702405f commit 61388933d3563916cfcc7fcbb059e0249e0c7c72
Showing with 2 additions and 2 deletions.
  1. +2 −2 pulsar/unackedMsgTracker.go
@@ -138,10 +138,10 @@ func (t *UnackedMessageTracker) Start(ackTimeoutMillis int64) {
defer t.cmu.Unlock()
t.timeout = time.NewTicker((time.Duration(ackTimeoutMillis)) * time.Millisecond)

go t.handlerCmd(ackTimeoutMillis)
go t.handlerCmd()
}

func (t *UnackedMessageTracker) handlerCmd(ackTimeoutMillis int64) {
func (t *UnackedMessageTracker) handlerCmd() {
for {
select {
case tick := <-t.timeout.C:

0 comments on commit 6138893

Please sign in to comment.
You can’t perform that action at this time.