jwkidd3

jwkidd3 / ZKConnect

Created January 19, 2017 04:39

	package com.kiddcorp.zk;

	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;

jwkidd3 / ZKNodeCreate

Created January 19, 2017 04:43

	package com.kiddcorp.zk;

	import org.apache.zookeeper.CreateMode;
	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.ZooDefs;
	import org.apache.zookeeper.ZooKeeper;

	/**
	*
	* @author jwkidd3

jwkidd3 / ZKNodeExists

Created January 19, 2017 04:45

	package com.kiddcorp.zk;

	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.ZooKeeper;
	import org.apache.zookeeper.data.Stat;
	/**
	*
	* @author jwkidd3
	*
	*/

jwkidd3 / ZKNodeData

Created January 19, 2017 04:50

	package com.kiddcorp.zk;

	import java.util.concurrent.CountDownLatch;

	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.WatchedEvent;
	import org.apache.zookeeper.Watcher;
	import org.apache.zookeeper.ZooKeeper;
	import org.apache.zookeeper.data.Stat;

jwkidd3 / ZKUpdateData

Created January 19, 2017 04:55

	package com.kiddcorp.zk;

	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.ZooKeeper;

	/**
	*
	* @author jwkidd3
	*
	*/

jwkidd3 / ZKGetChildren

Created January 19, 2017 05:03

	package com.kiddcorp.zk;

	import java.util.List;

	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.ZooKeeper;
	import org.apache.zookeeper.data.Stat;

	/**
	*

jwkidd3 / ZKDeleteNode

Created January 19, 2017 05:06

	package com.kiddcorp.zk;

	import org.apache.zookeeper.KeeperException;
	import org.apache.zookeeper.ZooKeeper;

	/**
	*
	* @author jwkidd3
	*
	*/

jwkidd3 / zkcompose

Created January 19, 2017 14:36

	version: '2'
	services:
	zoo1:
	image: zookeeper
	restart: always
	ports:
	- 2181:2181
	environment:
	ZOO_MY_ID: 1
	ZOO_SERVERS: server.1=zoo1:2888:3888 server.2=zoo2:2888:3888 server.3=zoo3:2888:3888

jwkidd3 / ZKBarrier

Created January 19, 2017 16:41

	public class SyncPrimitive implements Watcher {

	static ZooKeeper zk = null;
	static Integer mutex;

	String root;

	SyncPrimitive(String address) {
	if(zk == null){
	try {

jwkidd3 / ShutdownHook

Created March 9, 2017 14:54

	Runtime.getRuntime().addShutdownHook(new Thread() {

	@Override
	public void run() {
	for (TheConsumer consumerLoop : consumers) {
	consumerLoop.shutdown();
	}
	executor.shutdown();
	try {
	executor.awaitTermination(5000, TimeUnit.MILLISECONDS);