public static class ProtobufRpcEngine.Server extends RPC.Server
Server.AuthProtocol, Server.Call, Server.Connection
AUDITLOG, LOG, rpcDetailedMetrics, rpcMetrics
Constructor and Description |
---|
ProtobufRpcEngine.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.
|
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
public ProtobufRpcEngine.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 class of protocolprotocolImpl
- the protocolImpl 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 loggedportRangeConfig
- A config parameter that can be used to restrict
the range of ports used when port is 0 (an ephemeral port)IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.