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 -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.zookeeper.ZooKeepernewZooKeeperInstance(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher) Methods inherited from class org.apache.solr.common.cloud.DefaultConnectionStrategy
connect, reconnectMethods inherited from class org.apache.solr.common.cloud.ZkClientConnectionStrategy
addConnectedListener, addDisconnectedListener, connected, createZooKeeper, disconnected, forName, getZkCredentialsToAddAutomatically, hasZkCredentialsToAddAutomatically, removeDisconnectedListener, setZkCredentialsToAddAutomatically
-
Constructor Details
-
TestConnectionStrategy
public TestConnectionStrategy()
-
-
Method Details
-
newZooKeeperInstance
protected org.apache.zookeeper.ZooKeeper newZooKeeperInstance(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher) throws IOException - Overrides:
newZooKeeperInstancein classorg.apache.solr.common.cloud.ZkClientConnectionStrategy- Throws:
IOException
-