org.apache.zookeeper
public class ClientCnxn extends Object
Modifier and Type | Field and Description |
---|---|
static int |
packetLen |
Constructor and Description |
---|
ClientCnxn(String hosts,
int sessionTimeout,
ZooKeeper zooKeeper,
ClientWatchManager watcher)
Creates a connection object.
|
ClientCnxn(String hosts,
int sessionTimeout,
ZooKeeper zooKeeper,
ClientWatchManager watcher,
long sessionId,
byte[] sessionPasswd)
Creates a connection object.
|
Modifier and Type | Method and Description |
---|---|
void |
addAuthInfo(String scheme,
byte[] auth) |
void |
close()
Close the connection, which includes; send session disconnect to the
server, shutdown the send/event threads.
|
void |
disconnect()
Shutdown the send/event threads.
|
static boolean |
getDisableAutoResetWatch()
tests use this to check on reset of watches
|
long |
getSessionId() |
byte[] |
getSessionPasswd() |
int |
getSessionTimeout() |
static void |
setDisableAutoResetWatch(boolean b)
tests use this to set the auto reset
|
void |
start() |
ReplyHeader |
submitRequest(RequestHeader h,
org.apache.jute.Record request,
org.apache.jute.Record response,
org.apache.zookeeper.ZooKeeper.WatchRegistration watchRegistration) |
String |
toString() |
public ClientCnxn(String hosts, int sessionTimeout, ZooKeeper zooKeeper, ClientWatchManager watcher) throws IOException
hosts
- a comma separated list of hosts that can be connected to.sessionTimeout
- the timeout for connections.zooKeeper
- the zookeeper object that this connection is related to.watcher
- watcher for this connectionIOException
public ClientCnxn(String hosts, int sessionTimeout, ZooKeeper zooKeeper, ClientWatchManager watcher, long sessionId, byte[] sessionPasswd) throws IOException
hosts
- a comma separated list of hosts that can be connected to.sessionTimeout
- the timeout for connections.zooKeeper
- the zookeeper object that this connection is related to.watcher
- watcher for this connectionsessionId
- session id if re-establishing sessionsessionPasswd
- session passwd if re-establishing sessionIOException
public long getSessionId()
public byte[] getSessionPasswd()
public int getSessionTimeout()
public static boolean getDisableAutoResetWatch()
public static void setDisableAutoResetWatch(boolean b)
b
- the vaued to set disable watches topublic void start()
public void disconnect()
public void close() throws IOException
IOException
public ReplyHeader submitRequest(RequestHeader h, org.apache.jute.Record request, org.apache.jute.Record response, org.apache.zookeeper.ZooKeeper.WatchRegistration watchRegistration) throws InterruptedException
InterruptedException
public void addAuthInfo(String scheme, byte[] auth)
Copyright © 2014 The Apache Software Foundation