zk restart

ihaolin · Mar 3, 2017 · 8a3baff · 8a3baff
1 parent a48328d
commit 8a3baff
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/antares-common/src/main/java/me/hao0/antares/common/zk/ZkClient.java b/antares-common/src/main/java/me/hao0/antares/common/zk/ZkClient.java
@@ -513,7 +513,7 @@ public byte[] get(String path){
             return client.getData().forPath(path);
         } catch (Exception e){
             handleConnectionLoss(e);
-            throw new ZkException("failed to get path data");
+            throw new ZkException(e);
         }
     }
 

diff --git a/antares-common/src/test/java/me/hao0/antares/common/ZkClientTest.java b/antares-common/src/test/java/me/hao0/antares/common/ZkClientTest.java
@@ -112,6 +112,16 @@ public void testLock() throws InterruptedException {
         }
     }
 
+    @Test
+    public void testZkClientRestart(){
+
+        zk.get("/jobs");
+
+        zk.restart();
+
+        zk.get("/jobs");
+    }
+
     @After
     public void destroy(){
         if (zk != null){