public static class WritableRpcEngine.Server extends RPC.Server
Server.AuthProtocol, Server.Call, Server.ConnectionAUDITLOG, LOG, rpcDetailedMetrics, rpcMetrics| Constructor and Description |
|---|
WritableRpcEngine.Server(Class<?> protocolClass,
Object protocolImpl,
Configuration conf,
String bindAddress,
int port)
Construct an RPC server.
|
WritableRpcEngine.Server(Class<?> protocolClass,
Object protocolImpl,
Configuration conf,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct an RPC server.
|
WritableRpcEngine.Server(Object instance,
Configuration conf,
String bindAddress,
int port)
Deprecated.
Use #Server(Class, Object, Configuration, String, int)
|
WritableRpcEngine.Server(Object protocolImpl,
Configuration conf,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
SecretManager<? extends TokenIdentifier> secretManager)
Deprecated.
use Server#Server(Class, Object,
Configuration, String, int, int, int, int, boolean, SecretManager)
|
addProtocol, calladdTerseExceptions, bind, bind, call, get, getCallId, getCallQueueLen, getCallRetryCount, getClientId, getCurCall, getListenerAddress, getMaxQueueSize, getNumOpenConnections, getNumReaders, getPort, getRemoteAddress, getRemoteIp, getRemoteUser, getRpcDetailedMetrics, getRpcInvoker, getRpcMetrics, getRpcRequestWrapper, getServiceAuthorizationManager, isRpcInvocation, join, refreshServiceAcl, registerProtocolEngine, setSocketSendBufSize, start, stop@Deprecated public WritableRpcEngine.Server(Object instance, Configuration conf, String bindAddress, int port) throws IOException
instance - the instance whose methods will be calledconf - the configuration to usebindAddress - the address to bind on to listen for connectionport - the port to listen for connections onIOExceptionpublic WritableRpcEngine.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port) throws IOException
protocolClass - classprotocolImpl - the instance whose methods will be calledconf - the configuration to usebindAddress - the address to bind on to listen for connectionport - the port to listen for connections onIOException@Deprecated public WritableRpcEngine.Server(Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager) throws IOException
protocolImpl - the instance whose methods will be calledconf - the configuration to usebindAddress - the address to bind on to listen for connectionport - the port to listen for connections onnumHandlers - the number of method handler threads to runverbose - whether each call should be loggedIOExceptionpublic WritableRpcEngine.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) throws IOException
protocolClass - - the protocol being registered
can be null for compatibility with old usage (see below for details)protocolImpl - the protocol impl that will be calledconf - the configuration to usebindAddress - the address to bind on to listen for connectionport - the port to listen for connections onnumHandlers - the number of method handler threads to runverbose - whether each call should be loggedIOExceptionCopyright © 2013 Apache Software Foundation. All rights reserved.