public class NettyServerCnxnFactory extends ServerCnxnFactory
ServerCnxnFactory.PacketProcessor
cnxns, login, saslServerCallbackHandler, zkServer, ZOOKEEPER_SERVER_CNXN_FACTORY
Modifier and Type | Method and Description |
---|---|
void |
closeAll() |
void |
closeSession(long sessionId) |
void |
configure(java.net.InetSocketAddress addr,
int maxClientCnxns) |
java.lang.Iterable<ServerCnxn> |
getConnections() |
java.net.InetSocketAddress |
getLocalAddress() |
int |
getLocalPort() |
int |
getMaxClientCnxnsPerHost()
Maximum number of connections allowed from particular host (ip)
|
void |
join() |
void |
setMaxClientCnxnsPerHost(int max)
Maximum number of connections allowed from particular host (ip)
|
void |
shutdown() |
void |
start() |
void |
startup(ZooKeeperServer zks) |
configureSaslLogin, createFactory, createFactory, createFactory, getNumAliveConnections, registerConnection, setZooKeeperServer, unregisterConnection
public void closeAll()
closeAll
in class ServerCnxnFactory
public void closeSession(long sessionId)
closeSession
in class ServerCnxnFactory
public void configure(java.net.InetSocketAddress addr, int maxClientCnxns) throws java.io.IOException
configure
in class ServerCnxnFactory
java.io.IOException
public int getMaxClientCnxnsPerHost()
getMaxClientCnxnsPerHost
in class ServerCnxnFactory
public void setMaxClientCnxnsPerHost(int max)
setMaxClientCnxnsPerHost
in class ServerCnxnFactory
public int getLocalPort()
getLocalPort
in class ServerCnxnFactory
public void join() throws java.lang.InterruptedException
join
in class ServerCnxnFactory
java.lang.InterruptedException
public void shutdown()
shutdown
in class ServerCnxnFactory
public void start()
start
in class ServerCnxnFactory
public void startup(ZooKeeperServer zks) throws java.io.IOException, java.lang.InterruptedException
startup
in class ServerCnxnFactory
java.io.IOException
java.lang.InterruptedException
public java.lang.Iterable<ServerCnxn> getConnections()
getConnections
in class ServerCnxnFactory
public java.net.InetSocketAddress getLocalAddress()
getLocalAddress
in class ServerCnxnFactory
Copyright © 2023 The Apache Software Foundation