org.apache.hadoop.hbase.ipc

Class AsyncRpcChannel

java.lang.Object

org.apache.hadoop.hbase.ipc.AsyncRpcChannel

@InterfaceAudience.Private
public class AsyncRpcChannel
extends java.lang.Object

Netty RPC channel

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AsyncRpcChannel(Bootstrap bootstrap, AsyncRpcClient client, User ticket, java.lang.String serviceName, java.net.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(java.lang.Throwable e) Close connection
boolean	equals(java.lang.Object obj)
int	getConnectionHashCode()
int	hashCode()
boolean	isAlive() Check if the connection is alive
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

LOG

public static final Log LOG

tokenHandlers

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

Constructor Detail

AsyncRpcChannel

public AsyncRpcChannel(Bootstrap bootstrap,
                       AsyncRpcClient client,
                       User ticket,
                       java.lang.String serviceName,
                       java.net.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(java.lang.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()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object