upgrade to reactivemongo 0.11.11 which brings support for MongoDB 3.2…

….x and fixes numerous bugs (including an annoying bug preventing asynchronous authentication).

build.sbt

@@ -85,7 +85,7 @@ lazy val nosqlDependencies = Seq(
     "org.postgresql" % "postgresql" % "9.3-1102-jdbc41",
     "org.xerial" % "sqlite-jdbc" % "3.8.7",
     "org.apache.kafka" %% "kafka" % "0.8.2-beta",
-    "org.reactivemongo" %% "play2-reactivemongo" % "0.11.7.play23",
+    "org.reactivemongo" %% "play2-reactivemongo" % "0.11.11-play23",
     "com.datastax.cassandra" % "cassandra-driver-core" % "2.1.4",
     "org.elasticsearch" % "elasticsearch" % "1.4.4",
     "org.apache.hadoop" % "hadoop-client" % "2.6.0",
@@ -356,3 +356,5 @@ lazy val root = project
     .settings(EclipseKeys.skipParents in ThisBuild := false)
     .aggregate(api, aws, restapi, nlp, csv, dfs, dl, social, nosql, ml, web, tuktudb, crawler, modeller, viz, dlib)
     .dependsOn(api, aws, restapi, nlp, csv, dfs, dl, social, nosql, ml, web, tuktudb, crawler, modeller, viz, dlib)
+
+scalaVersion := "2.11.8"

conf/application.conf

@@ -136,4 +136,18 @@ akka {
 			#bind-port = 2552
         }
     }
+}
+
+# MongoDB Akka
+
+mongo-async-driver {
+    akka {
+        remote {
+            enabled-transports = ["akka.remote.netty.tcp"]
+            netty.tcp {
+                hostname = "127.0.0.1"
+                port = 4711
+            }
+       }
+    }
 }

modules/modeller/meta/generators/nosql/tuktu.nosql.generators.MongoDBFindGenerator.json

@@ -60,6 +60,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBAggregateProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBCleanupProcessor.json

@@ -0,0 +1,23 @@
+{
+	"name": "MongoDB Cleanup Processor",
+	"description": "Closes all MongodB connections.",
+	"class": "tuktu.nosql.processors.mongodb.MongoDBCleanupProcessor",
+	"parameters": [
+		{
+			"name": "id",
+			"type": "string",
+			"required": true
+		},
+		{
+			"name": "result",
+			"type": "string",
+			"required": true
+		},
+		{
+			"name": "config",
+			"type": "object",
+			"required": true,
+			"parameters": []
+		}
+	]
+}

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBFieldInsertProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBFindProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBFindStreamProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBInsertProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBRawCommandProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBRemoveProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBUpdateProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",

modules/modeller/meta/processors/nosql/mongodb/tuktu.nosql.processors.mongodb.MongoDBUpdatumProcessor.json

@@ -31,6 +31,13 @@
 						}
 					]
 				},
+				{
+					"name": "conn",
+					"description": "Number of channels (connections) per node.",
+					"type": "int",
+					"required": false,
+					"default": 10
+				},
 				{
 					"name": "database",
 					"description": "The database name.",