Package org.apache.storm.daemon.drpc
Class DRPC
java.lang.Object
org.apache.storm.daemon.drpc.DRPC
- All Implemented Interfaces:
- AutoCloseable
- 
Constructor SummaryConstructorsConstructorDescriptionDRPC(StormMetricsRegistry metricsRegistry, Map<String, Object> conf) DRPC(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()<T extends OutstandingRequest>
 Texecute(String functionName, String funcArgs, RequestFactory<T> factory) executeBlocking(String functionName, String funcArgs) voidfetchRequest(String functionName) voidreturnResult(String id, String result) 
- 
Constructor Details- 
DRPC
- 
DRPC
 
- 
- 
Method Details- 
returnResult- Throws:
- AuthorizationException
 
- 
fetchRequest- Throws:
- AuthorizationException
 
- 
failRequest- Throws:
- AuthorizationException
 
- 
executepublic <T extends OutstandingRequest> T execute(String functionName, String funcArgs, RequestFactory<T> factory) throws AuthorizationException - Throws:
- AuthorizationException
 
- 
executeBlockingpublic String executeBlocking(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException 
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
 
 
-