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
 }