Package org.apache.storm.daemon.drpc
Class DRPCServer
java.lang.Object
org.apache.storm.daemon.drpc.DRPCServer
- All Implemented Interfaces:
- AutoCloseable
- 
Constructor SummaryConstructorsConstructorDescriptionDRPCServer(Map<String, Object> conf, StormMetricsRegistry metricsRegistry) Constructor.
- 
Method SummaryModifier and TypeMethodDescriptionstatic voidaddRequestContextFilter(org.eclipse.jetty.servlet.ServletContextHandler context, String configName, Map<String, Object> conf) Add a request context filter to the Servlet Context Handler.voidclose()intThe port the DRPC invoke server is listening on.intThe port the DRPC handler server is listening on.intThe port the HTTP server is listening on.static voidMain method to start the server.
- 
Constructor Details- 
DRPCServerConstructor.- Parameters:
- conf- Drpc conf for the servers
- metricsRegistry- The metrics registry
 
 
- 
- 
Method Details- 
addRequestContextFilterpublic static void addRequestContextFilter(org.eclipse.jetty.servlet.ServletContextHandler context, String configName, Map<String, Object> conf) Add a request context filter to the Servlet Context Handler.- Parameters:
- context- The Servlet Context handler
- configName- Config name
- conf- Conf to be added in context filter
 
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
 
- 
getDrpcPortpublic int getDrpcPort()The port the DRPC handler server is listening on.- Returns:
- The port the DRPC handler server is listening on.
 
- 
getDrpcInvokePortpublic int getDrpcInvokePort()The port the DRPC invoke server is listening on.- Returns:
- The port the DRPC invoke server is listening on.
 
- 
getHttpServerPortpublic int getHttpServerPort()The port the HTTP server is listening on. Not available untilstart()has run.- Returns:
- The port the HTTP server is listening on. Not available until start()has run.
 
- 
mainMain method to start the server.- Throws:
- Exception
 
 
-