com.baidu.brpc.protocol

Interface Response

All Known Implementing Classes:

AbstractResponse, HttpResponse, RpcResponse

public interface Response

Method Summary

Modifier and Type	Method and Description
io.netty.buffer.ByteBuf	getBinaryAttachment()
int	getCompressType()
long	getCorrelationId() used to find RpcFuture, application can not set it.
Throwable	getException()
Map<String,Object>	getKvAttachment()
long	getLogId() used to identify request for application, application can set it.
NSHead	getNsHead()
Object	getResult()
RpcFuture	getRpcFuture()
RpcMethodInfo	getRpcMethodInfo()
SPHead	getSpHead()
boolean	isHeartbeat()
void	reset()
void	setBinaryAttachment(io.netty.buffer.ByteBuf binaryAttachment)
void	setCompressType(int compressType)
void	setCorrelationId(long correlationId)
void	setException(Throwable exception)
void	setHeartbeat(boolean heartbeat)
void	setKvAttachment(Map<String,Object> kvAttachment)
void	setLogId(long logId)
void	setNsHead(NSHead nsHead)
void	setResult(Object result)
void	setRpcFuture(RpcFuture rpcFuture)
void	setRpcMethodInfo(RpcMethodInfo rpcMethodInfo)

Method Detail

getResult

Object getResult()

setResult

void setResult(Object result)

getCorrelationId

long getCorrelationId()

used to find RpcFuture, application can not set it.

Returns:

rpc future id

setCorrelationId

void setCorrelationId(long correlationId)

getLogId

long getLogId()

used to identify request for application, application can set it.

Returns:

application request id

setLogId

void setLogId(long logId)

getException

Throwable getException()

getNsHead

NSHead getNsHead()

getSpHead

SPHead getSpHead()

setNsHead

void setNsHead(NSHead nsHead)

setException

void setException(Throwable exception)

getRpcMethodInfo

RpcMethodInfo getRpcMethodInfo()

setRpcMethodInfo

void setRpcMethodInfo(RpcMethodInfo rpcMethodInfo)

getRpcFuture

RpcFuture getRpcFuture()

setRpcFuture

void setRpcFuture(RpcFuture rpcFuture)

getKvAttachment

Map<String,Object> getKvAttachment()

setKvAttachment

void setKvAttachment(Map<String,Object> kvAttachment)

getBinaryAttachment

io.netty.buffer.ByteBuf getBinaryAttachment()

setBinaryAttachment

void setBinaryAttachment(io.netty.buffer.ByteBuf binaryAttachment)

getCompressType

int getCompressType()

setCompressType

void setCompressType(int compressType)

isHeartbeat

boolean isHeartbeat()

setHeartbeat

void setHeartbeat(boolean heartbeat)

reset

void reset()