public abstract class ZkClientConnectionStrategy extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
ZkClientConnectionStrategy.ConnectedListener |
static interface |
ZkClientConnectionStrategy.DisconnectedListener |
static interface |
ZkClientConnectionStrategy.ZkUpdate |
Constructor and Description |
---|
ZkClientConnectionStrategy() |
public abstract void connect(String zkServerAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater) throws IOException, InterruptedException, TimeoutException
public abstract void reconnect(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher, ZkClientConnectionStrategy.ZkUpdate updater) throws IOException, InterruptedException, TimeoutException
public void disconnected()
public void connected()
public void addDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
public void removeDisconnectedListener(ZkClientConnectionStrategy.DisconnectedListener listener)
public void addConnectedListener(ZkClientConnectionStrategy.ConnectedListener listener)
public void setZkCredentialsToAddAutomatically(ZkCredentialsProvider zkCredentialsToAddAutomatically)
public boolean hasZkCredentialsToAddAutomatically()
public ZkCredentialsProvider getZkCredentialsToAddAutomatically()
protected SolrZooKeeper createSolrZooKeeper(String serverAddress, int zkClientTimeout, org.apache.zookeeper.Watcher watcher) throws IOException
IOException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.