Fixed cancel zookeeper node path issue
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/21c1cdb1 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/21c1cdb1 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/21c1cdb1 Branch: refs/heads/master Commit: 21c1cdb1675025d77637d6526f40a551a6d07f70 Parents: 4e57f5b Author: Shameera Rathanyaka <[email protected]> Authored: Fri Sep 4 16:28:38 2015 -0400 Committer: Supun Nakandala <[email protected]> Committed: Sat Sep 5 12:24:24 2015 +0530 ---------------------------------------------------------------------- .../java/org/apache/airavata/gfac/server/GfacServerHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/21c1cdb1/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java b/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java index 8427cdc..94dbc57 100644 --- a/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java +++ b/modules/gfac/gfac-service/src/main/java/org/apache/airavata/gfac/server/GfacServerHandler.java @@ -336,7 +336,7 @@ public class GfacServerHandler implements GfacService.Iface { curatorClient.getData().usingWatcher(Factory.getCancelRequestWatcher()).forPath(cancelListenerNode);*/ // create /experiments/{experimentId}/cancel node and set watcher for data changes - String experimentCancelNode = experimentNodePath + "/" + ZkConstants.ZOOKEEPER_CANCEL_LISTENER_NODE; + String experimentCancelNode = ZKPaths.makePath(experimentNodePath, ZkConstants.ZOOKEEPER_CANCEL_LISTENER_NODE); ZKPaths.mkdirs(curatorClient.getZookeeperClient().getZooKeeper(), experimentCancelNode); curatorClient.getData().usingWatcher(Factory.getCancelRequestWatcher()).forPath (experimentCancelNode);
