IGNITE-2718: Added Zookeeper IP finder dependencies. - Fixes #522. Signed-off-by: shtykh_roman <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3b44cc4f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3b44cc4f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3b44cc4f Branch: refs/heads/ignite-1232 Commit: 3b44cc4fec50b17ecd9ab4d155edf461f02361fc Parents: 452673d Author: shtykh_roman <[email protected]> Authored: Wed Mar 2 12:02:27 2016 +0900 Committer: shtykh_roman <[email protected]> Committed: Wed Mar 2 12:02:27 2016 +0900 ---------------------------------------------------------------------- modules/zookeeper/pom.xml | 50 +++++++++++++++++++- .../tcp/ipfinder/zk/ZookeeperIpFinderTest.java | 24 ++++++---- 2 files changed, 63 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3b44cc4f/modules/zookeeper/pom.xml ---------------------------------------------------------------------- diff --git a/modules/zookeeper/pom.xml b/modules/zookeeper/pom.xml index e296b55..b749c30 100644 --- a/modules/zookeeper/pom.xml +++ b/modules/zookeeper/pom.xml @@ -20,7 +20,8 @@ <!-- POM file. --> -<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> <modelVersion>4.0.0</modelVersion> <parent> @@ -55,6 +56,53 @@ <dependency> <groupId>org.apache.curator</groupId> + <artifactId>curator-client</artifactId> + <version>${curator.version}</version> + </dependency> + + <dependency> + <groupId>com.google.guava</groupId> + <artifactId>guava</artifactId> + <version>${guava16.version}</version> + </dependency> + + <dependency> + <groupId>org.codehaus.jackson</groupId> + <artifactId>jackson-core-asl</artifactId> + <version>${jackson.version}</version> + </dependency> + + <dependency> + <groupId>org.codehaus.jackson</groupId> + <artifactId>jackson-mapper-asl</artifactId> + <version>${jackson.version}</version> + </dependency> + + <dependency> + <groupId>org.apache.zookeeper</groupId> + <artifactId>zookeeper</artifactId> + <version>${zookeeper.version}</version> + </dependency> + + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-api</artifactId> + <version>${slf4j.version}</version> + </dependency> + + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-log4j12</artifactId> + <version>${slf4j.version}</version> + </dependency> + + <dependency> + <groupId>log4j</groupId> + <artifactId>log4j</artifactId> + </dependency> + + <dependency> + <groupId>org.apache.curator</groupId> <artifactId>curator-test</artifactId> <version>${curator.version}</version> <scope>test</scope> http://git-wip-us.apache.org/repos/asf/ignite/blob/3b44cc4f/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java index 1b91163..3f9b1ff 100644 --- a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java +++ b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/tcp/ipfinder/zk/ZookeeperIpFinderTest.java @@ -27,6 +27,7 @@ import org.apache.curator.retry.ExponentialBackoffRetry; import org.apache.curator.retry.RetryNTimes; import org.apache.curator.test.InstanceSpec; import org.apache.curator.test.TestingCluster; +import org.apache.curator.utils.CloseableUtils; import org.apache.ignite.Ignite; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.events.Event; @@ -65,6 +66,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { /** * Before test. + * * @throws Exception */ @Override public void beforeTest() throws Exception { @@ -73,6 +75,9 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { // remove stale system properties System.getProperties().remove(TcpDiscoveryZookeeperIpFinder.PROP_ZK_CONNECTION_STRING); + // disable JMX for tests + System.setProperty("zookeeper.jmx.log4j.disable", "true"); + // start the ZK cluster zkCluster = new TestingCluster(ZK_CLUSTER_SIZE); zkCluster.start(); @@ -84,18 +89,17 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { /** * After test. + * * @throws Exception */ @Override public void afterTest() throws Exception { super.afterTest(); if (zkCurator != null) - zkCurator.close(); + CloseableUtils.closeQuietly(zkCurator); - if (zkCluster != null) { - zkCluster.stop(); - zkCluster.close(); - } + if (zkCluster != null) + CloseableUtils.closeQuietly(zkCluster); stopAllGrids(); } @@ -110,7 +114,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { IgniteConfiguration configuration = super.getConfiguration(gridName); - TcpDiscoverySpi tcpDisco = (TcpDiscoverySpi) configuration.getDiscoverySpi(); + TcpDiscoverySpi tcpDisco = (TcpDiscoverySpi)configuration.getDiscoverySpi(); TcpDiscoveryZookeeperIpFinder zkIpFinder = new TcpDiscoveryZookeeperIpFinder(); zkIpFinder.setAllowDuplicateRegistrations(allowDuplicateRegistrations); @@ -147,7 +151,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { startGrid(0); // set up an event listener to expect one NODE_JOINED event - CountDownLatch latch = expectJoinEvents(grid(0), 1); + CountDownLatch latch = expectJoinEvents(grid(0), 1); // start the other node startGrid(1); @@ -170,7 +174,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { startGrid(0); // set up an event listener to expect one NODE_JOINED event - CountDownLatch latch = expectJoinEvents(grid(0), 2); + CountDownLatch latch = expectJoinEvents(grid(0), 2); // start the 2nd node startGrid(1); @@ -201,7 +205,7 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { startGrid(0); // set up an event listener to expect one NODE_JOINED event - CountDownLatch latch = expectJoinEvents(grid(0), 3); + CountDownLatch latch = expectJoinEvents(grid(0), 3); // start the 2nd node startGrid(1); @@ -392,4 +396,4 @@ public class ZookeeperIpFinderTest extends GridCommonAbstractTest { return latch; } -} \ No newline at end of file +}
