org.apache.hadoop.hbase.ipc

Class AsyncRpcChannel

java.lang.Object

org.apache.hadoop.hbase.ipc.AsyncRpcChannel

@InterfaceAudience.Private
public class AsyncRpcChannel
extends Object

Netty RPC channel

Field Summary

Fields

Modifier and Type	Field and Description
static Log	LOG
protected static Map<AuthenticationProtos.TokenIdentifier.Kind,<any>>	tokenHandlers

Constructor Summary

Constructors

Constructor and Description
AsyncRpcChannel(Bootstrap bootstrap, AsyncRpcClient client, User ticket, String serviceName, InetSocketAddress address) Constructor for netty RPC channel

Method Summary

Modifier and Type	Method and Description
<any>	callMethod(Descriptors.MethodDescriptor method, PayloadCarryingRpcController controller, Message request, Message responsePrototype) Calls method on channel
void	close(Throwable e) Close connection
int	getConnectionHashCode()
boolean	isAlive() Check if the connection is alive
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Log LOG

tokenHandlers

protected static final Map<AuthenticationProtos.TokenIdentifier.Kind,<any>> tokenHandlers

Constructor Detail

AsyncRpcChannel

public AsyncRpcChannel(Bootstrap bootstrap,
                       AsyncRpcClient client,
                       User ticket,
                       String serviceName,
                       InetSocketAddress address)

Constructor for netty RPC channel

Parameters:

bootstrap - to construct channel on

client - to connect with

ticket - of user which uses connection

serviceName - name of service to connect to

address - to connect to

Method Detail

callMethod

public <any> callMethod(Descriptors.MethodDescriptor method,
                        PayloadCarryingRpcController controller,
                        Message request,
                        Message responsePrototype)

Calls method on channel

Parameters:

method - to call

controller - to run call with

request - to send

responsePrototype - to construct response with

close

public void close(Throwable e)

Close connection

Parameters:

e - exception on close

isAlive

public boolean isAlive()

Check if the connection is alive

Returns:

true if alive

getConnectionHashCode

public int getConnectionHashCode()

toString

public String toString()

Overrides:

toString in class Object