public interface RpcCall extends RpcCallContext
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Do the necessary cleanup after the call if needed.
|
CellScanner |
getCellScanner() |
long |
getDeadline()
Return the deadline of this call.
|
RequestHeader |
getHeader() |
MethodDescriptor |
getMethod() |
Message |
getParam() |
int |
getPriority() |
long |
getReceiveTime() |
int |
getRemotePort() |
BlockingService |
getService() |
long |
getSize()
Used to calculate the request call queue size.
|
long |
getStartTime() |
int |
getTimeout() |
void |
sendResponseIfReady()
Send the response of this RPC call.
|
void |
setResponse(Message param,
CellScanner cells,
java.lang.Throwable errorThrowable,
java.lang.String error)
Set the response resulting from this RPC call.
|
void |
setStartTime(long startTime)
Set the time when the call starts to be executed.
|
java.lang.String |
toShortString() |
disconnectSince, getClientVersionInfo, getRemoteAddress, getRequestUser, getRequestUserName, getResponseBlockSize, getResponseCellSize, getResponseExceptionSize, incrementResponseBlockSize, incrementResponseCellSize, incrementResponseExceptionSize, isClientCellBlockSupported, isRetryImmediatelySupported, setCallBack
BlockingService getService()
MethodDescriptor getMethod()
Message getParam()
CellScanner getCellScanner()
long getReceiveTime()
long getStartTime()
void setStartTime(long startTime)
int getTimeout()
int getPriority()
long getDeadline()
long getSize()
RequestHeader getHeader()
int getRemotePort()
void setResponse(Message param, CellScanner cells, java.lang.Throwable errorThrowable, java.lang.String error)
param
- The result message as response.cells
- The CellScanner that possibly carries the payload.errorThrowable
- The error Throwable resulting from the call.error
- Extra error message.void sendResponseIfReady() throws java.io.IOException
java.io.IOException
void cleanup()
java.lang.String toShortString()