Package org.apache.solr.common.cloud

Class ZkClientConnectionStrategy

java.lang.Object

org.apache.solr.common.cloud.ZkClientConnectionStrategy

Direct Known Subclasses:

DefaultConnectionStrategy

public abstract class ZkClientConnectionStrategy
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ZkClientConnectionStrategy.ConnectedListener
static interface	ZkClientConnectionStrategy.DisconnectedListener
static interface	ZkClientConnectionStrategy.ZkUpdate

Constructor Summary

Constructors

Constructor	Description
ZkClientConnectionStrategy()

Method Summary

Modifier and Type	Method	Description
void	addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)
void	addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
abstract void	connect(String zkServerAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)
void	connected()
protected org.apache.zookeeper.ZooKeeper	createZooKeeper(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher)
void	disconnected()
static ZkClientConnectionStrategy	forName(String name, ZkClientConnectionStrategy def)	Instantiate a new connection strategy for the given class name
ZkCredentialsProvider	getZkCredentialsToAddAutomatically()
boolean	hasZkCredentialsToAddAutomatically()
protected org.apache.zookeeper.ZooKeeper	newZooKeeperInstance(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher)
abstract void	reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)
void	removeDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
void	setZkCredentialsToAddAutomatically(ZkCredentialsProvider zkCredentialsToAddAutomatically)

Methods inherited from class java.lang.Object

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

Constructor Details

ZkClientConnectionStrategy

public ZkClientConnectionStrategy()

Method Details

connect

public abstract void connect(String zkServerAddress,
 int zkClientTimeout,
 org.apache.zookeeper.Watcher watcher,
 ZkClientConnectionStrategy.ZkUpdate updater)
                      throws IOException,
InterruptedException,
TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

reconnect

public abstract void reconnect(String serverAddress,
 int zkClientTimeout,
 org.apache.zookeeper.Watcher watcher,
 ZkClientConnectionStrategy.ZkUpdate updater)
                        throws IOException,
InterruptedException,
TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

disconnected

public void disconnected()

connected

public void connected()

addDisconnectedListener

public void addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)

removeDisconnectedListener

public void removeDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)

addConnectedListener

public void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)

setZkCredentialsToAddAutomatically

public void setZkCredentialsToAddAutomatically(ZkCredentialsProvider zkCredentialsToAddAutomatically)

hasZkCredentialsToAddAutomatically

public boolean hasZkCredentialsToAddAutomatically()

getZkCredentialsToAddAutomatically

public ZkCredentialsProvider getZkCredentialsToAddAutomatically()

createZooKeeper

protected org.apache.zookeeper.ZooKeeper createZooKeeper(String serverAddress,
 int zkClientTimeout,
 org.apache.zookeeper.Watcher watcher)
                                                  throws IOException

Throws:

IOException

newZooKeeperInstance

protected org.apache.zookeeper.ZooKeeper newZooKeeperInstance(String serverAddress,
 int zkClientTimeout,
 org.apache.zookeeper.Watcher watcher)
                                                       throws IOException

Throws:

IOException

forName

public static ZkClientConnectionStrategy forName(String name,
 ZkClientConnectionStrategy def)

Instantiate a new connection strategy for the given class name

Parameters:

name - the name of the strategy to use

Returns:

the strategy instance, or null if it could not be loaded