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 voidfail(DRPCExecutionException e)StringgetResult()voidreturnResult(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:
returnResultin classOutstandingRequest
-
fail
public void fail(DRPCExecutionException e)
- Specified by:
failin classOutstandingRequest
-
-