From bb3752c3a1553afdcad4c711343dd70b58c0d4df Mon Sep 17 00:00:00 2001 From: Michael Wilner Date: Wed, 31 Oct 2018 13:31:58 -0500 Subject: [PATCH] Close iterator when getting messages --- mongostore.go | 1 + 1 file changed, 1 insertion(+) diff --git a/mongostore.go b/mongostore.go index b57232c40..bac1cd50a 100644 --- a/mongostore.go +++ b/mongostore.go @@ -244,6 +244,7 @@ func (store *mongoStore) GetMessages(beginSeqNum, endSeqNum int) (msgs [][]byte, for iter.Next(msgFilter) { msgs = append(msgs, msgFilter.Message) } + err = iter.Close() return }