fix test

uber-archive · Aug 16, 2017 · 5a9e811 · 5a9e811
1 parent 511f7ea
commit 5a9e811
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/services/outputhost/messagecache_test.go b/services/outputhost/messagecache_test.go
@@ -117,14 +117,14 @@ func (s *MessageCacheSuite) TestTimerQueueCleanupAfterRedelivery() {
 		}
 
 		cMsg.msg.AckId = common.StringPtr(ackIDStr)
-		s.msgCache.utilHandleDeliveredMsg(cMsg, nil)
+		s.msgCache.utilHandleDeliveredMsg(cMsg)
 		ackIDMap[ackIDStr] = struct{}{}
 		ackID++
 	}
 
 	time.Sleep(time.Second)
 
-	s.msgCache.utilHandleRedeliveryTicker(nil)
+	s.msgCache.utilHandleRedeliveryTicker()
 	s.Equal(100, len(s.msgRedeliveryCh), "Unexpected message cache redelivery")
 
 	for i := 0; i < 100; i++ {
@@ -134,7 +134,7 @@ func (s *MessageCacheSuite) TestTimerQueueCleanupAfterRedelivery() {
 		delete(ackIDMap, m.GetAckId())
 	}
 
-	s.msgCache.utilHandleRedeliveryTicker(nil)
+	s.msgCache.utilHandleRedeliveryTicker()
 	s.Equal(0, len(s.msgRedeliveryCh), "Unexpected message cache redelivery")
 }