org.apache.solr.common.cloud
Class ZkClientConnectionStrategy

java.lang.Object
  extended by org.apache.solr.common.cloud.ZkClientConnectionStrategy
Direct Known Subclasses:
DefaultConnectionStrategy

public abstract class ZkClientConnectionStrategy
extends Object


Nested Class Summary
static interface ZkClientConnectionStrategy.ConnectedListener
           
static interface ZkClientConnectionStrategy.DisconnectedListener
           
static class ZkClientConnectionStrategy.ZkUpdate
           
 
Constructor Summary
ZkClientConnectionStrategy()
           
 
Method Summary
 void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)
           
 void addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
           
abstract  void connect(String zkServerAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)
           
 void connected()
           
 void disconnected()
           
abstract  void reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZkClientConnectionStrategy

public ZkClientConnectionStrategy()
Method Detail

connect

public abstract void connect(String zkServerAddress,
                             int zkClientTimeout,
                             org.apache.zookeeper.Watcher watcher,
                             ZkClientConnectionStrategy.ZkUpdate updater)
                      throws IOException,
                             InterruptedException,
                             TimeoutException
Throws:
IOException
InterruptedException
TimeoutException

reconnect

public abstract void reconnect(String serverAddress,
                               int zkClientTimeout,
                               org.apache.zookeeper.Watcher watcher,
                               ZkClientConnectionStrategy.ZkUpdate updater)
                        throws IOException,
                               InterruptedException,
                               TimeoutException
Throws:
IOException
InterruptedException
TimeoutException

disconnected

public void disconnected()

connected

public void connected()

addDisconnectedListener

public void addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)

addConnectedListener

public void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)


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