org.springframework.xd.dirt.zookeeper

Class ZooKeeperConnection

java.lang.Object

org.springframework.xd.dirt.zookeeper.ZooKeeperConnection

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

public class ZooKeeperConnection
extends java.lang.Object
implements org.springframework.context.SmartLifecycle

A wrapper for a CuratorFramework instance whose lifecycle is managed as a Spring bean. Accepts ZooKeeperConnectionListeners to be notified when connection or disconnection events are received.

Author:

Mark Fisher, David Turanski

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_CLIENT_CONNECT_STRING The default client connect string.

Constructor Summary

Constructors

Constructor and Description
ZooKeeperConnection() Establish a ZooKeeper connection with the default client connect string: "localhost:2181"
ZooKeeperConnection(java.lang.String clientConnectString) Establish a ZooKeeper connection with the provided client connect string.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addListener(ZooKeeperConnectionListener listener) Add a ZooKeeperConnectionListener.
org.apache.curator.framework.CuratorFramework	getClient() Provides access to the underlying CuratorFramework instance.
int	getPhase()
org.apache.curator.RetryPolicy	getRetryPolicy() Return the Curator retry policy.
boolean	isAutoStartup()
boolean	isConnected() Checks whether the underlying connection is established.
boolean	isRunning() Check whether this client is running.
boolean	removeListener(ZooKeeperConnectionListener listener) Remove a ZooKeeperConnectionListener.
void	setAutoStartup(boolean autoStartup) Set the flag that indicates whether this connection should be started automatically.
void	setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy) Set the Curator retry policy.
void	start() Starts the underlying CuratorFramework instance.
void	stop() Closes the underlying CuratorFramework instance.
void	stop(java.lang.Runnable callback) Closes the underlying CuratorFramework instance and then invokes the callback.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CLIENT_CONNECT_STRING

public static final java.lang.String DEFAULT_CLIENT_CONNECT_STRING

The default client connect string. Port 2181 on localhost.

See Also:

Constant Field Values

Constructor Detail

ZooKeeperConnection

public ZooKeeperConnection()

Establish a ZooKeeper connection with the default client connect string: "localhost:2181"

ZooKeeperConnection

public ZooKeeperConnection(java.lang.String clientConnectString)

Establish a ZooKeeper connection with the provided client connect string.

Parameters:

clientConnectString - one or more host:port strings, comma-delimited if more than one

Method Detail

isConnected

public boolean isConnected()

Checks whether the underlying connection is established.

Returns:

true if connected

getClient

public org.apache.curator.framework.CuratorFramework getClient()

Provides access to the underlying CuratorFramework instance.

Returns:

the CuratorFramework instance

addListener

public boolean addListener(ZooKeeperConnectionListener listener)

Add a ZooKeeperConnectionListener.

Parameters:

listener - the listener to add

Returns:

true if the listener was added or false if it was already registered

removeListener

public boolean removeListener(ZooKeeperConnectionListener listener)

Remove a ZooKeeperConnectionListener.

Parameters:

listener - the listener to remove

Returns:

true if the listener was removed or false if it was never registered

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

setAutoStartup

public void setAutoStartup(boolean autoStartup)

Set the flag that indicates whether this connection should be started automatically.

Parameters:

autoStartup - if true, indicates this connection should be started automatically

setRetryPolicy

public void setRetryPolicy(org.apache.curator.RetryPolicy retryPolicy)

Set the Curator retry policy.

Parameters:

retryPolicy - Curator client RetryPolicy

getRetryPolicy

public org.apache.curator.RetryPolicy getRetryPolicy()

Return the Curator retry policy.

Returns:

the Curator retry policy

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

isRunning

public boolean isRunning()

Check whether this client is running.

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Starts the underlying CuratorFramework instance.

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Closes the underlying CuratorFramework instance.

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public void stop(java.lang.Runnable callback)

Closes the underlying CuratorFramework instance and then invokes the callback.

Specified by:

stop in interface org.springframework.context.SmartLifecycle