org.apache.twill.zookeeper

Class ZKClients

java.lang.Object

org.apache.twill.zookeeper.ZKClients

public final class ZKClients
extends Object

Utility class to create ZKClient instances.

Method Summary

Modifier and Type	Method and Description
static ZKClient	namespace(ZKClient zkClient, String namespace) Creates a ZKClient that will add prefix namespace for every paths.
static ZKClient	retryOnFailure(ZKClient client, RetryStrategy retryStrategy) Creates a ZKClient that will retry interim failure (e.g.
static ZKClient	reWatchOnExpire(ZKClient client) Creates a ZKClient that will perform auto re-watch on all existing watches when reconnection happens after session expiration.

Methods inherited from class java.lang.Object

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

Method Detail

reWatchOnExpire

public static ZKClient reWatchOnExpire(ZKClient client)

Creates a ZKClient that will perform auto re-watch on all existing watches when reconnection happens after session expiration. All Watchers set through the returned ZKClient would not receive any connection events.

Parameters:

client - The ZKClient for operations delegation.

Returns:

A ZKClient that will do auto re-watch on all methods that accept a Watcher upon session expiration.

retryOnFailure

public static ZKClient retryOnFailure(ZKClient client,
                                      RetryStrategy retryStrategy)

Creates a ZKClient that will retry interim failure (e.g. connection loss, session expiration) based on the given RetryStrategy.

Parameters:

client - The ZKClient for operations delegation.

retryStrategy - The RetryStrategy to be invoke when there is operation failure.

Returns:

A ZKClient.

namespace

public static ZKClient namespace(ZKClient zkClient,
                                 String namespace)

Creates a ZKClient that will add prefix namespace for every paths.

Parameters:

zkClient - The ZKClient for operations delegation.

namespace - The prefix namespace to be prepended to paths.

Returns:

A ZKClient that will add namespace to every path.