org.apache.tinkerpop.gremlin.driver

Class Channelizer.AbstractChannelizer

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

org.apache.tinkerpop.gremlin.driver.Channelizer.AbstractChannelizer

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, Channelizer

Direct Known Subclasses:

Channelizer.NioChannelizer, Channelizer.WebSocketChannelizer

Enclosing interface:

Channelizer

public abstract static class Channelizer.AbstractChannelizer
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>
implements Channelizer

Base implementation of the client side Channelizer.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.driver.Channelizer

Channelizer.AbstractChannelizer, Channelizer.NioChannelizer, Channelizer.WebSocketChannelizer

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected Cluster	cluster
protected org.apache.tinkerpop.gremlin.driver.Connection	connection
protected static String	PIPELINE_GREMLIN_HANDLER
protected static String	PIPELINE_GREMLIN_SASL_HANDLER

Constructor Summary

Constructors

Constructor and Description
AbstractChannelizer()

Method Summary

Modifier and Type	Method and Description
void	close(io.netty.channel.Channel channel) Called on Connection.closeAsync() to perform an Channelizer specific functions.
abstract void	configure(io.netty.channel.ChannelPipeline pipeline)
void	finalize(io.netty.channel.ChannelPipeline pipeline)
void	init(org.apache.tinkerpop.gremlin.driver.Connection connection) Initializes the Channelizer.
protected void	initChannel(io.netty.channel.socket.SocketChannel socketChannel)
boolean	supportsSsl()

Methods inherited from class io.netty.channel.ChannelInitializer

channelRegistered, exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tinkerpop.gremlin.driver.Channelizer

connected, createKeepAliveMessage, supportsKeepAlive

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Field Detail

connection

protected org.apache.tinkerpop.gremlin.driver.Connection connection

cluster

protected Cluster cluster

PIPELINE_GREMLIN_SASL_HANDLER

protected static final String PIPELINE_GREMLIN_SASL_HANDLER

See Also:

Constant Field Values

PIPELINE_GREMLIN_HANDLER

protected static final String PIPELINE_GREMLIN_HANDLER

See Also:

Constant Field Values

Constructor Detail

AbstractChannelizer

public AbstractChannelizer()

Method Detail

supportsSsl

public boolean supportsSsl()

configure

public abstract void configure(io.netty.channel.ChannelPipeline pipeline)

finalize

public void finalize(io.netty.channel.ChannelPipeline pipeline)

close

public void close(io.netty.channel.Channel channel)

Description copied from interface: Channelizer

Called on Connection.closeAsync() to perform an Channelizer specific functions. Note that the Connection already calls Channel.close() so there is no need to call that method here. An implementation will typically use this method to send a Channelizer specific message to the server to notify of shutdown coming from the client side (e.g. a "close" websocket frame).

Specified by:

close in interface Channelizer

init

public void init(org.apache.tinkerpop.gremlin.driver.Connection connection)

Description copied from interface: Channelizer

Initializes the Channelizer. Called just after construction.

Specified by:

init in interface Channelizer

initChannel

protected void initChannel(io.netty.channel.socket.SocketChannel socketChannel)
                    throws Exception

Specified by:

initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

Throws:

Exception