Package 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

Modifier and Type	Class	Description
static interface	ConnectionManager.IsClosed

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

org.apache.zookeeper.Watcher.Event, org.apache.zookeeper.Watcher.WatcherType

Constructor Summary

Constructors

Constructor	Description
ConnectionManager(String name, SolrZkClient client, String zkServerAddress, ZkClientConnectionStrategy strat, OnReconnect onConnect, BeforeReconnect beforeReconnect, ConnectionManager.IsClosed isClosed)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isConnected()
boolean	isConnectedAndNotClosed()
boolean	isLikelyExpired()
void	process(org.apache.zookeeper.WatchedEvent event)
void	waitForConnected(long waitForConnection)	Wait for an established zookeeper connection
void	waitForDisconnected(long timeout)
void	waitSleep(long waitFor)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionManager

public ConnectionManager(String name,
                         SolrZkClient client,
                         String zkServerAddress,
                         ZkClientConnectionStrategy strat,
                         OnReconnect onConnect,
                         BeforeReconnect beforeReconnect,
                         ConnectionManager.IsClosed isClosed)

Method Detail

process

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

Specified by:

process in interface org.apache.zookeeper.Watcher

isConnectedAndNotClosed

public boolean isConnectedAndNotClosed()

isConnected

public boolean isConnected()

close

public void close()

isLikelyExpired

public boolean isLikelyExpired()

waitSleep

public void waitSleep(long waitFor)

waitForConnected

public void waitForConnected(long waitForConnection)
                      throws TimeoutException

Wait for an established zookeeper connection

Parameters:

waitForConnection - time to wait, in ms

Throws:

TimeoutException

waitForDisconnected

public void waitForDisconnected(long timeout)
                         throws InterruptedException,
                                TimeoutException

Throws:

InterruptedException

TimeoutException