diff --git a/output/recorder.go b/output/recorder.go
index <HASH>..<HASH> 100644
--- a/output/recorder.go
+++ b/output/recorder.go
@@ -172,7 +172,7 @@ func (r *Recorder) doSave(msg *models.Message) {
 	}
 }
 
-func (r *Recorder) close(msg *models.Message) error {
+func (r *Recorder) close() {
 	r.session.Close()
 	r.session = nil
 	r.collection = nil
trying harder to get more stability in recorder