Package org.apache.hadoop.oncrpc

Class RpcResponse

java.lang.Object

io.netty.channel.DefaultAddressedEnvelope<io.netty.buffer.ByteBuf,SocketAddress>

org.apache.hadoop.oncrpc.RpcResponse

All Implemented Interfaces:

io.netty.channel.AddressedEnvelope<io.netty.buffer.ByteBuf,SocketAddress>, io.netty.util.ReferenceCounted

public class RpcResponse
extends io.netty.channel.DefaultAddressedEnvelope<io.netty.buffer.ByteBuf,SocketAddress>

RpcResponse encapsulates a response to a RPC request. It contains the data that is going to cross the wire, as well as the information of the remote peer.

Constructor Summary

Constructors

Constructor	Description
RpcResponse(io.netty.buffer.ByteBuf message, SocketAddress recipient)
RpcResponse(io.netty.buffer.ByteBuf message, SocketAddress recipient, SocketAddress sender)

Method Summary

Modifier and Type	Method	Description
io.netty.buffer.ByteBuf	data()
SocketAddress	remoteAddress()

Methods inherited from class io.netty.channel.DefaultAddressedEnvelope

content, recipient, refCnt, release, release, retain, retain, sender, toString, touch, touch

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RpcResponse

public RpcResponse(io.netty.buffer.ByteBuf message,
 SocketAddress recipient)

RpcResponse

public RpcResponse(io.netty.buffer.ByteBuf message,
 SocketAddress recipient,
 SocketAddress sender)

Method Details

data

public io.netty.buffer.ByteBuf data()

remoteAddress

public SocketAddress remoteAddress()