org.broadleafcommerce.core.util

Class ZookeeperUtil

java.lang.Object

org.broadleafcommerce.core.util.ZookeeperUtil

public class ZookeeperUtil
extends Object

Simple utility to assist in basic operations related to Zookeeper.

Author:

Kelly Tisdell

Constructor Summary

Constructors

Constructor and Description
ZookeeperUtil()

Method Summary

Modifier and Type	Method and Description
static void	deleteRecursive(String path, org.apache.zookeeper.ZooKeeper zk) Recursively deletes a path in Zookeeper.
static boolean	exists(String path, org.apache.zookeeper.ZooKeeper zk)
static void	makePath(String path, byte[] data, org.apache.zookeeper.ZooKeeper zk)
static void	makePath(String path, byte[] data, org.apache.zookeeper.ZooKeeper zk, org.apache.zookeeper.CreateMode createMode)
static void	makePath(String path, byte[] data, org.apache.zookeeper.ZooKeeper zk, org.apache.zookeeper.CreateMode createMode, List<org.apache.zookeeper.data.ACL> acls) Creates a path in Zookeeper, specified by the path argument.
static void	makePath(String path, org.apache.zookeeper.ZooKeeper zk) Creates a path in Zookeeper, if it does not already exist, with CreateMode.PERSISTENT for the create mode and ZooDefs.Ids.OPEN_ACL_UNSAFE for ACLs.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZookeeperUtil

public ZookeeperUtil()

Method Detail

deleteRecursive

public static void deleteRecursive(String path,
                                   org.apache.zookeeper.ZooKeeper zk)
                            throws org.apache.zookeeper.KeeperException,
                                   InterruptedException

Recursively deletes a path in Zookeeper. For example, if you have a path like /path/to/my/element, then passing "/path" to this method will delete the directory tree recursively.

Parameters:

path -

zk -

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

makePath

public static void makePath(String path,
                            org.apache.zookeeper.ZooKeeper zk)
                     throws org.apache.zookeeper.KeeperException,
                            InterruptedException

Creates a path in Zookeeper, if it does not already exist, with CreateMode.PERSISTENT for the create mode and ZooDefs.Ids.OPEN_ACL_UNSAFE for ACLs. If any part of the path exists, then the rest of this path will be appended to it..

Parameters:

path -

zk -

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

makePath

public static void makePath(String path,
                            byte[] data,
                            org.apache.zookeeper.ZooKeeper zk)
                     throws org.apache.zookeeper.KeeperException,
                            InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

makePath

public static void makePath(String path,
                            byte[] data,
                            org.apache.zookeeper.ZooKeeper zk,
                            org.apache.zookeeper.CreateMode createMode)
                     throws org.apache.zookeeper.KeeperException,
                            InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

makePath

public static void makePath(String path,
                            byte[] data,
                            org.apache.zookeeper.ZooKeeper zk,
                            org.apache.zookeeper.CreateMode createMode,
                            List<org.apache.zookeeper.data.ACL> acls)
                     throws org.apache.zookeeper.KeeperException,
                            InterruptedException

Creates a path in Zookeeper, specified by the path argument. For example: /path/to/my/element. If part or all of the path already exists, then it will not be created. If the data byte array is not null and has a size greater than 0, then it will be added to the final node of the path. If the final node of the path already exists, then the data will be ignored. If the ACLs are null or empty, then ZooDefs.Ids.OPEN_ACL_UNSAFE will be used. If createMode is null, then CreateMode.PERSISTENT will be used.

Parameters:

path -

data -

zk -

createMode -

acls -

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

exists

public static boolean exists(String path,
                             org.apache.zookeeper.ZooKeeper zk)
                      throws org.apache.zookeeper.KeeperException,
                             InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException