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 and 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 and 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 Detail

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)