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

protected static org.slf4j.Logger

log

Constructor Summary

ConnectionManager(String name, SolrZkClient client, String zkServerAddress, ZkClientConnectionStrategy strat, OnReconnect onConnect, BeforeReconnect beforeReconnect)

Method Summary

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,
                         ZkClientConnectionStrategy strat,
                         OnReconnect onConnect,
                         BeforeReconnect beforeReconnect)

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