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 and Description
DefaultConnectionStrategy()

Method Summary

Methods

Modifier and Type	Method and 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, createSolrZooKeeper, disconnected, hasZkCredentialsToAddAutomatically, setZkCredentialsToAddAutomatically

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConnectionStrategy

public DefaultConnectionStrategy()

Method Detail

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

Specified by:

reconnect in class ZkClientConnectionStrategy

Throws:

IOException