public static class WritableRpcEngine.Server extends RPC.Server
Server.AuthProtocol, Server.Call, Server.Connection
AUDITLOG, 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, call
addTerseExceptions, 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 onIOException
public 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 loggedIOException
public 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 loggedIOException
Copyright © 2013 Apache Software Foundation. All rights reserved.