Fix for #159

Author: richardwilly98

Diff for: src/main/java/org/elasticsearch/river/mongodb/MongoDBRiverDefinition.java

@@ -344,7 +344,7 @@ public synchronized static MongoDBRiverDefinition parseSettings(String riverName
                     ArrayList<Map<String, Object>> feeds = (ArrayList<Map<String, Object>>) mongoServersSettings;
                     for (Map<String, Object> feed : feeds) {
                         mongoHost = XContentMapValues.nodeStringValue(feed.get(HOST_FIELD), null);
-                        mongoPort = XContentMapValues.nodeIntegerValue(feed.get(PORT_FIELD), 0);
+                        mongoPort = XContentMapValues.nodeIntegerValue(feed.get(PORT_FIELD), DEFAULT_DB_PORT);
                         logger.info("Server: " + mongoHost + " - " + mongoPort);
                         try {
                             mongoServers.add(new ServerAddress(mongoHost, mongoPort));

Diff for: src/test/java/org/elasticsearch/river/mongodb/MongoDBRiverDefinitionTest.java

@@ -11,7 +11,10 @@
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
+import com.mongodb.ServerAddress;
+
 public class MongoDBRiverDefinitionTest {
+
     @Test
     public void testLoadMongoDBRiverDefinition() {
         try {
@@ -39,4 +42,29 @@ public void testLoadMongoDBRiverDefinition() {
             Assert.fail("testLoadMongoDBRiverDefinition failed", t);
         }
     }
+
+    @Test
+    public void testLoadMongoDBRiverDefinitionIssue159() {
+        try {
+            RiverName riverName = new RiverName("mongodb", "mongodb-" + System.currentTimeMillis());
+            InputStream in = getClass().getResourceAsStream("/org/elasticsearch/river/mongodb/test-mongodb-river-definition-159.json");
+            RiverSettings riverSettings = new RiverSettings(ImmutableSettings.settingsBuilder().build(), XContentHelper.convertToMap(
+                    Streams.copyToByteArray(in), false).v2());
+            ScriptService scriptService = null;
+            MongoDBRiverDefinition definition = MongoDBRiverDefinition.parseSettings(riverName.name(), "my-river-index", riverSettings,
+                    scriptService);
+            Assert.assertNotNull(definition);
+
+            Assert.assertEquals(2, definition.getMongoServers().size());
+            ServerAddress serverAddress = definition.getMongoServers().get(0);
+            Assert.assertEquals(serverAddress.getHost(), "127.0.0.1");
+            Assert.assertEquals(serverAddress.getPort(), MongoDBRiverDefinition.DEFAULT_DB_PORT);
+            serverAddress = definition.getMongoServers().get(1);
+            Assert.assertEquals(serverAddress.getHost(), "localhost");
+            Assert.assertEquals(serverAddress.getPort(), MongoDBRiverDefinition.DEFAULT_DB_PORT);
+
+        } catch (Throwable t) {
+            Assert.fail("testLoadMongoDBRiverDefinitionIssue159 failed", t);
+        }
+    }
 }

Diff for: src/test/java/org/elasticsearch/river/mongodb/test-mongodb-river-definition-159.json

@@ -0,0 +1,28 @@
+{
+	"type": "mongodb",
+	"mongodb": {
+		"servers": [
+			{host: "127.0.0.1"},
+			{host: "localhost"}
+		],
+		"options": {
+			"connect_timeout": 11000,
+			"secondary_read_preference": true,
+			"include_collection": "mycollection",
+			"advanced_transformation": true,
+			"parent_types": ["parent1", "parent2"]
+		},
+		"credentials": [{
+			db: "admin",
+			user: "admin",
+			password: "secret"
+		}],
+		db: "mydatabase",
+		collection: "mycollection",
+		gridfs: "false"
+	},
+	index: {
+		name: "myindex",
+		throttle_size: 2000
+	}
+}