Package org.apache.drill.exec.rpc

Class ConnectionMultiListener<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>>

java.lang.Object

org.apache.drill.exec.rpc.ConnectionMultiListener<T,CC,HS,HR,BC>

Type Parameters:

CC - Client Connection Listener

HS - Outbound handshake message type

HR - Inbound handshake message type

BC - BasicClient type

Implements a wrapper class that allows a client connection to associate different behaviours after establishing a connection with the server. The client can choose to send an application handshake, or in the case of SSL, wait for a SSL handshake completion and then send an application handshake.

public class ConnectionMultiListener<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConnectionMultiListener.Builder<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite,BC extends BasicClient<T,CC,HS,HR>>
static class	ConnectionMultiListener.SSLHandshakeListener

Method Summary

Modifier and Type	Method	Description
static <T extends com.google.protobuf.Internal.EnumLite, CC extends ClientConnection, HS extends com.google.protobuf.MessageLite, HR extends com.google.protobuf.MessageLite, BC extends BasicClient<T, CC, HS, HR>> ConnectionMultiListener.Builder<T,CC,HS,HR,BC>	newBuilder(RpcConnectionHandler<CC> connectionListener, HS handshakeValue, BC basicClient)

Methods inherited from class java.lang.Object

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

Method Details

newBuilder

public static <T extends com.google.protobuf.Internal.EnumLite,
CC extends ClientConnection,
HS extends com.google.protobuf.MessageLite,
HR extends com.google.protobuf.MessageLite,
BC extends BasicClient<T,
CC,
HS,
HR>>
ConnectionMultiListener.Builder<T,CC,HS,HR,BC> newBuilder(RpcConnectionHandler<CC> connectionListener,
 HS handshakeValue,
 BC basicClient)