Merge pull request #14 from diegopacheco/dev

FIX connection bug introduced n 0.7 and change key from x_ to x
diegopacheco · Nov 2, 2017 · f6d3fe2 · f6d3fe2
2 parents baa1b3a + 204f9a9
commit f6d3fe2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...c/main/java/com/github/diegopacheco/dynomite/cluster/checker/parser/DynomiteNodeInfo.java b/...c/main/java/com/github/diegopacheco/dynomite/cluster/checker/parser/DynomiteNodeInfo.java
@@ -43,7 +43,8 @@ public String toJsonTopology(){
 	}
 
 	public Host toHOST(){
-		return new Host(this.getServer(),this.getPort(),this.getRack(),Status.Up);
+		Integer port = Integer.parseInt(this.getPort());
+		return new Host(this.getServer(),port,this.getRack(),Status.Up);
 	}
 
 	public String toSeed(){

diff --git a/...va/com/github/diegopacheco/dynomite/cluster/checker/tasks/CheckNodesConnectivityTask.java b/...va/com/github/diegopacheco/dynomite/cluster/checker/tasks/CheckNodesConnectivityTask.java
@@ -66,7 +66,7 @@ private List<DynomiteNodeInfo> checkNodeConnectivity(ExecutionContext ec) {
 					ClientCache.put(node.toSeed(), client);
 				}
 
-				String prefix = "awesomeSbrubles_";
+				String prefix = "awesomeSbrubles";
 				client.get(prefix);
 
 				node.setNodeClient(client);