Removing error - topology is closed

Changed line 73 to fix the connection issue to mongodb
TIBCOSoftware · Aug 13, 2018 · adac5e1 · adac5e1
1 parent 117cf95
commit adac5e1
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/activity/mongodb/activity.go b/activity/mongodb/activity.go
@@ -70,7 +70,13 @@ func (a *MongoDbActivity) Eval(ctx activity.Context) (done bool, err error) {
 	value := ctx.GetInput(ivData)
 
 	//todo implement shared sessions
-	client, err := mongo.NewClient(connectionURI)
+	// client, err := mongo.NewClient(connectionURI)
+	/*
+	The above function was giving below error;
+	"data not inserted topology is closed"
+	*/
+
+	client, err := mongo.Connect(context.Background(), connectionURI, nil)
 	if err != nil {
 		activityLog.Errorf("Connection error: %v", err)
 		return false, err