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 and Description
static interface	ZkClientConnectionStrategy.ConnectedListener
static interface	ZkClientConnectionStrategy.DisconnectedListener
static class	ZkClientConnectionStrategy.ZkUpdate

Constructor Summary

Constructors

Constructor and Description
ZkClientConnectionStrategy()

Method Summary

Methods

Modifier and Type	Method and 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()
void	disconnected()
abstract void	reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkClientConnectionStrategy

public ZkClientConnectionStrategy()

Method Detail

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)

addConnectedListener

public void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)