diff --git a/sysmodule/mongodbmodule/mongodbmodule.go b/sysmodule/mongodbmodule/mongodbmodule.go index 6846202..830ae55 100644 --- a/sysmodule/mongodbmodule/mongodbmodule.go +++ b/sysmodule/mongodbmodule/mongodbmodule.go @@ -47,6 +47,10 @@ func (mm *MongoModule) Start() error { return nil } +func (mm *MongoModule) Stop() error { + return mm.client.Disconnect(context.Background()) +} + func (mm *MongoModule) TakeSession() Session { return Session{Client: mm.client, maxOperatorTimeOut: mm.maxOperatorTimeOut} }