Package org.apache.solr.cloud

Class TestConnectionStrategy

java.lang.Object

org.apache.solr.common.cloud.ZkClientConnectionStrategy

org.apache.solr.common.cloud.DefaultConnectionStrategy

org.apache.solr.cloud.TestConnectionStrategy

public class TestConnectionStrategy
extends org.apache.solr.common.cloud.DefaultConnectionStrategy

Connection strategy that creates instances of TestableZooKeeper instead of plain ZooKeeper objects. Useful for adding pause and disconnect events.

Nested Class Summary

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

org.apache.solr.common.cloud.ZkClientConnectionStrategy.ConnectedListener, org.apache.solr.common.cloud.ZkClientConnectionStrategy.DisconnectedListener, org.apache.solr.common.cloud.ZkClientConnectionStrategy.ZkUpdate

Constructor Summary

Constructors

Constructor	Description
TestConnectionStrategy()

Method Summary

Modifier and Type	Method	Description
protected org.apache.zookeeper.ZooKeeper	newZooKeeperInstance(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher)

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

connect, reconnect

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TestConnectionStrategy

public TestConnectionStrategy()

Method Detail

newZooKeeperInstance

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

Overrides:

newZooKeeperInstance in class org.apache.solr.common.cloud.ZkClientConnectionStrategy

Throws:

IOException