zk
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4ec75fa2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4ec75fa2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4ec75fa2 Branch: refs/heads/ignite-zk Commit: 4ec75fa2900e3f4624d6516e0c50fc1877d7b5cc Parents: aa0ca90 Author: sboikov <sboi...@gridgain.com> Authored: Wed Nov 15 13:12:26 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Wed Nov 15 13:12:26 2017 +0300 ---------------------------------------------------------------------- .../ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/4ec75fa2/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java index cee9e65..6488a6f 100644 --- a/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java +++ b/modules/zookeeper/src/main/java/org/apache/ignite/spi/discovery/zk/ZookeeperDiscoverySpi.java @@ -315,12 +315,12 @@ public class ZookeeperDiscoverySpi extends IgniteSpiAdapter implements Discovery /** {@inheritDoc} */ @Override public void sendCustomEvent(DiscoverySpiCustomMessage msg) throws IgniteException { // TODO ZK - try { - zkCurator.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).forPath(CUSTOM_EVTS_PATH, marshal(msg)); - } - catch (Exception e) { - throw new IgniteSpiException(e); - } +// try { +// zkCurator.create().withMode(CreateMode.PERSISTENT_SEQUENTIAL).forPath(CUSTOM_EVTS_PATH, marshal(msg)); +// } +// catch (Exception e) { +// throw new IgniteSpiException(e); +// } } /** {@inheritDoc} */