Package org.apache.solr.common.cloud

Class DefaultConnectionStrategy

java.lang.Object

org.apache.solr.common.cloud.ZkClientConnectionStrategy

org.apache.solr.common.cloud.DefaultConnectionStrategy

public class DefaultConnectionStrategy
extends ZkClientConnectionStrategy

TODO: improve backoff retry impl

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.common.cloud.ZkClientConnectionStrategy

ZkClientConnectionStrategy.ConnectedListener, ZkClientConnectionStrategy.DisconnectedListener, ZkClientConnectionStrategy.ZkUpdate

Constructor Summary

Constructors

Constructor	Description
DefaultConnectionStrategy()

Method Summary

Modifier and Type	Method	Description
void	connect(String serverAddress, int timeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)
void	reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)

Methods inherited from class org.apache.solr.common.cloud.ZkClientConnectionStrategy

addConnectedListener, addDisconnectedListener, connected, createZooKeeper, disconnected, forName, getZkCredentialsToAddAutomatically, hasZkCredentialsToAddAutomatically, newZooKeeperInstance, removeDisconnectedListener, setZkCredentialsToAddAutomatically

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultConnectionStrategy

public DefaultConnectionStrategy()

Method Details

connect

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

Specified by:

connect in class ZkClientConnectionStrategy

Throws:

IOException

InterruptedException

TimeoutException

reconnect

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

Specified by:

reconnect in class ZkClientConnectionStrategy

Throws:

IOException

InterruptedException

TimeoutException