org.apache.solr.common.cloud

Class ConnectionManager

java.lang.Object

org.apache.solr.common.cloud.ConnectionManager

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class ConnectionManager
extends Object
implements org.apache.zookeeper.Watcher

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
ConnectionManager(String name, SolrZkClient client, String zkServerAddress, int zkClientTimeout, ZkClientConnectionStrategy strat, OnReconnect onConnect)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	isConnected()
boolean	isLikelyExpired()
void	process(org.apache.zookeeper.WatchedEvent event)
void	waitForConnected(long waitForConnection)
void	waitForDisconnected(long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

Constructor Detail

ConnectionManager

public ConnectionManager(String name,
                 SolrZkClient client,
                 String zkServerAddress,
                 int zkClientTimeout,
                 ZkClientConnectionStrategy strat,
                 OnReconnect onConnect)

Method Detail

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher

isConnected

public boolean isConnected()

close

public void close()

isLikelyExpired

public boolean isLikelyExpired()

waitForConnected

public void waitForConnected(long waitForConnection)
                      throws TimeoutException

Throws:

TimeoutException

waitForDisconnected

public void waitForDisconnected(long timeout)
                         throws InterruptedException,
                                TimeoutException

Throws:

InterruptedException

TimeoutException