Package org.apache.storm.daemon.drpc
Class BlockingOutstandingRequest
- java.lang.Object
-
- org.apache.storm.daemon.drpc.OutstandingRequest
-
- org.apache.storm.daemon.drpc.BlockingOutstandingRequest
-
public class BlockingOutstandingRequest extends OutstandingRequest
-
-
Field Summary
Fields Modifier and Type Field Description static RequestFactory<BlockingOutstandingRequest>
FACTORY
-
Constructor Summary
Constructors Constructor Description BlockingOutstandingRequest(String function, DRPCRequest req)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
fail(DRPCExecutionException e)
String
getResult()
void
returnResult(String result)
-
Methods inherited from class org.apache.storm.daemon.drpc.OutstandingRequest
fetched, getFunction, getRequest, isTimedOut, wasFetched
-
-
-
-
Field Detail
-
FACTORY
public static final RequestFactory<BlockingOutstandingRequest> FACTORY
-
-
Constructor Detail
-
BlockingOutstandingRequest
public BlockingOutstandingRequest(String function, DRPCRequest req)
-
-
Method Detail
-
getResult
public String getResult() throws DRPCExecutionException
- Throws:
DRPCExecutionException
-
returnResult
public void returnResult(String result)
- Specified by:
returnResult
in classOutstandingRequest
-
fail
public void fail(DRPCExecutionException e)
- Specified by:
fail
in classOutstandingRequest
-
-