From 29be61157c1a83e6baac75efbe242d70f2500193 Mon Sep 17 00:00:00 2001
From: cheetah100 <cheetah100@gmail.com>
Date: Sun, 24 Jan 2016 08:45:34 +1300
Subject: [PATCH] Modification of MongoDB connection to connect to multiple
 hosts

---
 .../net/orcon/kanban/tools/OcmMapperFactory.java | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/main/java/nz/net/orcon/kanban/tools/OcmMapperFactory.java b/src/main/java/nz/net/orcon/kanban/tools/OcmMapperFactory.java
index b47de05..9998b29 100644
--- a/src/main/java/nz/net/orcon/kanban/tools/OcmMapperFactory.java
+++ b/src/main/java/nz/net/orcon/kanban/tools/OcmMapperFactory.java
@@ -48,6 +48,7 @@ import org.slf4j.LoggerFactory;
 
 import com.mongodb.DB;
 import com.mongodb.MongoClient;
+import com.mongodb.ServerAddress;
 
 public class OcmMapperFactory {
 	
@@ -80,10 +81,18 @@ public class OcmMapperFactory {
 		
 		if(this.repository==null){
 			logger.info("Creating Repository");
-			// MEMORY REPO
-			// repository = new Jcr(new Oak()).createRepository();
 			
-			DB db = new MongoClient(host, 27017).getDB("gravity");
+			String[] hostArray = this.getHost().split(",");
+			List<String> hostList = Arrays.asList(hostArray);
+			
+			List<ServerAddress> serverList = new ArrayList<ServerAddress>();
+			for( String hostURL : hostList){
+				ServerAddress sa = new ServerAddress(hostURL);
+				serverList.add(sa);
+			}
+			
+			MongoClient mc = new MongoClient(serverList);
+			DB db = mc.getDB("gravity");
 		    DocumentNodeStore ns = new DocumentMK.Builder().
 		            setMongoDB(db).getNodeStore();		    
 		    
@@ -198,5 +207,4 @@ public class OcmMapperFactory {
 	public void setHost(String host) {
 		this.host = host;
 	}
-
 }
-- 
GitLab