ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [5/5] ignite git commit: zk
Date Wed, 15 Nov 2017 10:12:42 GMT
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 <sboikov@gridgain.com>
Authored: Wed Nov 15 13:12:26 2017 +0300
Committer: sboikov <sboikov@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} */


Mime
View raw message