org.apache.solr.common.cloud
Class ConnectionManager

java.lang.Object
  extended by 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


Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.