Repository: airavata Updated Branches: refs/heads/master 39a0365d8 -> 2c4044cd6
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/12a4800c Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/12a4800c Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/12a4800c Branch: refs/heads/master Commit: 12a4800cfc2f7f90306b5f36f3bed4c6a3996e49 Parents: 60e657d Author: Shameera Rathanyaka <[email protected]> Authored: Fri Sep 4 16:28:38 2015 -0400 Committer: Shameera Rathanyaka <[email protected]> Committed: Fri Sep 4 16:28:38 2015 -0400 ---------------------------------------------------------------------- .../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/12a4800c/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);
