Package org.apache.storm.daemon.drpc
Class DRPC
java.lang.Object
org.apache.storm.daemon.drpc.DRPC
- All Implemented Interfaces:
AutoCloseable
-
Constructor Summary
ConstructorDescriptionDRPC
(StormMetricsRegistry metricsRegistry, Map<String, Object> conf) DRPC
(StormMetricsRegistry metricsRegistry, IAuthorizer auth, long timeoutMs) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
<T extends OutstandingRequest>
Texecute
(String functionName, String funcArgs, RequestFactory<T> factory) executeBlocking
(String functionName, String funcArgs) void
fetchRequest
(String functionName) void
returnResult
(String id, String result)
-
Constructor Details
-
DRPC
-
DRPC
-
-
Method Details
-
returnResult
- Throws:
AuthorizationException
-
fetchRequest
- Throws:
AuthorizationException
-
failRequest
- Throws:
AuthorizationException
-
execute
public <T extends OutstandingRequest> T execute(String functionName, String funcArgs, RequestFactory<T> factory) throws AuthorizationException - Throws:
AuthorizationException
-
executeBlocking
public String executeBlocking(String functionName, String funcArgs) throws DRPCExecutionException, AuthorizationException -
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-