From 5a9e8113a264a08fc4a7a92a7965561394e6c883 Mon Sep 17 00:00:00 2001 From: Kobe Yang Date: Wed, 16 Aug 2017 11:09:08 -0700 Subject: [PATCH] fix test --- services/outputhost/messagecache_test.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/services/outputhost/messagecache_test.go b/services/outputhost/messagecache_test.go index b83b6c11..c820877a 100644 --- 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") }