From 689482831a99f24c701f01029fcb1ecf6e344abe Mon Sep 17 00:00:00 2001 From: sampadawagde Date: Fri, 12 Jun 2020 12:13:41 +0530 Subject: [PATCH] JAVA-1848: Moved apache-zookeeper to apache-libraries --- apache-zookeeper/README.md | 7 --- apache-zookeeper/pom.xml | 31 ---------- .../zookeeper/connection/ZKConnection.java | 33 ----------- .../baeldung/zookeeper/manager/ZKManager.java | 35 ----------- .../zookeeper/manager/ZKManagerImpl.java | 58 ------------------- .../src/main/resources/logback.xml | 13 ----- 6 files changed, 177 deletions(-) delete mode 100644 apache-zookeeper/README.md delete mode 100644 apache-zookeeper/pom.xml delete mode 100644 apache-zookeeper/src/main/java/com/baeldung/zookeeper/connection/ZKConnection.java delete mode 100644 apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManager.java delete mode 100644 apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManagerImpl.java delete mode 100644 apache-zookeeper/src/main/resources/logback.xml diff --git a/apache-zookeeper/README.md b/apache-zookeeper/README.md deleted file mode 100644 index cda1cd6d73..0000000000 --- a/apache-zookeeper/README.md +++ /dev/null @@ -1,7 +0,0 @@ -## Apache Zookeeper - -This module contains articles about Apache Zookeeper - -### Relevant articles: - -- [Getting Started with Java and Zookeeper](https://www.baeldung.com/java-zookeeper) diff --git a/apache-zookeeper/pom.xml b/apache-zookeeper/pom.xml deleted file mode 100644 index f441848f70..0000000000 --- a/apache-zookeeper/pom.xml +++ /dev/null @@ -1,31 +0,0 @@ - - - 4.0.0 - apache-zookeeper - 0.0.1-SNAPSHOT - apache-zookeeper - jar - - - com.baeldung - parent-modules - 1.0.0-SNAPSHOT - - - - - org.apache.zookeeper - zookeeper - ${org.apache.zookeeper.version} - - - - - 3.4.11 - - - - diff --git a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/connection/ZKConnection.java b/apache-zookeeper/src/main/java/com/baeldung/zookeeper/connection/ZKConnection.java deleted file mode 100644 index 0678250d57..0000000000 --- a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/connection/ZKConnection.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.baeldung.zookeeper.connection; - -import java.io.IOException; -import java.util.concurrent.CountDownLatch; - -import org.apache.zookeeper.WatchedEvent; -import org.apache.zookeeper.Watcher; -import org.apache.zookeeper.Watcher.Event.KeeperState; -import org.apache.zookeeper.ZooKeeper; - -public class ZKConnection { - private ZooKeeper zoo; - final CountDownLatch connectionLatch = new CountDownLatch(1); - - public ZKConnection() { - } - - public ZooKeeper connect(String host) throws IOException, InterruptedException { - zoo = new ZooKeeper(host, 2000, new Watcher() { - public void process(WatchedEvent we) { - if (we.getState() == KeeperState.SyncConnected) { - connectionLatch.countDown(); - } - } - }); - connectionLatch.await(); - return zoo; - } - - public void close() throws InterruptedException { - zoo.close(); - } -} diff --git a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManager.java b/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManager.java deleted file mode 100644 index 0c0ad52123..0000000000 --- a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManager.java +++ /dev/null @@ -1,35 +0,0 @@ -package com.baeldung.zookeeper.manager; - -import org.apache.zookeeper.KeeperException; - -public interface ZKManager { - /** - * Create a Znode and save some data - * - * @param path - * @param data - * @throws KeeperException - * @throws InterruptedException - */ - public void create(String path, byte[] data) throws KeeperException, InterruptedException; - - /** - * Get ZNode Data - * - * @param path - * @param boolean watchFlag - * @throws KeeperException - * @throws InterruptedException - */ - public Object getZNodeData(String path, boolean watchFlag); - - /** - * Update the ZNode Data - * - * @param path - * @param data - * @throws KeeperException - * @throws InterruptedException - */ - public void update(String path, byte[] data) throws KeeperException, InterruptedException, KeeperException; -} diff --git a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManagerImpl.java b/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManagerImpl.java deleted file mode 100644 index adf76bc0f2..0000000000 --- a/apache-zookeeper/src/main/java/com/baeldung/zookeeper/manager/ZKManagerImpl.java +++ /dev/null @@ -1,58 +0,0 @@ -package com.baeldung.zookeeper.manager; - -import org.apache.zookeeper.CreateMode; -import org.apache.zookeeper.KeeperException; -import org.apache.zookeeper.ZooDefs; -import org.apache.zookeeper.ZooKeeper; - -import com.baeldung.zookeeper.connection.ZKConnection; - -public class ZKManagerImpl implements ZKManager { - private static ZooKeeper zkeeper; - private static ZKConnection zkConnection; - - public ZKManagerImpl() { - initialize(); - } - - /** * Initialize connection */ - private void initialize() { - try { - zkConnection = new ZKConnection(); - zkeeper = zkConnection.connect("localhost"); - } catch (Exception e) { - System.out.println(e.getMessage()); - } - } - - public void closeConnection() { - try { - zkConnection.close(); - } catch (InterruptedException e) { - System.out.println(e.getMessage()); - } - } - - public void create(String path, byte[] data) throws KeeperException, InterruptedException { - zkeeper.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); - } - - public Object getZNodeData(String path, boolean watchFlag) { - try { - byte[] b = null; - b = zkeeper.getData(path, null, null); - String data = new String(b, "UTF-8"); - System.out.println(data); - return data; - } catch (Exception e) { - System.out.println(e.getMessage()); - } - return null; - } - - public void update(String path, byte[] data) throws KeeperException, InterruptedException { - int version = zkeeper.exists(path, true) - .getVersion(); - zkeeper.setData(path, data, version); - } -} diff --git a/apache-zookeeper/src/main/resources/logback.xml b/apache-zookeeper/src/main/resources/logback.xml deleted file mode 100644 index 7d900d8ea8..0000000000 --- a/apache-zookeeper/src/main/resources/logback.xml +++ /dev/null @@ -1,13 +0,0 @@ - - - - - %d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n - - - - - - - - \ No newline at end of file