public class ConnectionManager extends Object implements org.apache.zookeeper.Watcher
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionManager.IsClosed |
Constructor and Description |
---|
ConnectionManager(String name,
SolrZkClient client,
String zkServerAddress,
ZkClientConnectionStrategy strat,
OnReconnect onConnect,
BeforeReconnect beforeReconnect,
ConnectionManager.IsClosed isClosed) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
isConnected() |
boolean |
isConnectedAndNotClosed() |
boolean |
isLikelyExpired() |
void |
process(org.apache.zookeeper.WatchedEvent event) |
void |
waitForConnected(long waitForConnection) |
void |
waitForDisconnected(long timeout) |
void |
waitSleep(long waitFor) |
public ConnectionManager(String name, SolrZkClient client, String zkServerAddress, ZkClientConnectionStrategy strat, OnReconnect onConnect, BeforeReconnect beforeReconnect, ConnectionManager.IsClosed isClosed)
public void process(org.apache.zookeeper.WatchedEvent event)
process
in interface org.apache.zookeeper.Watcher
public boolean isConnectedAndNotClosed()
public boolean isConnected()
public void close()
public boolean isLikelyExpired()
public void waitSleep(long waitFor)
public void waitForConnected(long waitForConnection) throws TimeoutException
TimeoutException
public void waitForDisconnected(long timeout) throws InterruptedException, TimeoutException
InterruptedException
TimeoutException
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.