Package org.apache.tinkerpop.gremlin.server

Class 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.server.AbstractChannelizer

All Implemented Interfaces:

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

Direct Known Subclasses:

HttpChannelizer

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

A base implementation for the Channelizer which does a basic configuration of the pipeline, one that is generally common to virtually any Gremlin Server operation (i.e. where the server's purpose is to process Gremlin scripts).

Implementers need only worry about determining how incoming data is converted to a RequestMessage and outgoing data is converted from a ResponseMessage to whatever expected format is needed by the pipeline.

Author:

Stephen Mallette (http://stephen.genoprime.com)

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
protected Authenticator	authenticator
protected Authorizer	authorizer
protected io.netty.channel.group.ChannelGroup	channels
protected static final List<Settings.SerializerSettings>	DEFAULT_SERIALIZERS
protected GraphManager	graphManager
protected static final String	GREMLIN_ENDPOINT
protected GremlinExecutor	gremlinExecutor
protected ExecutorService	gremlinExecutorService
static final String	PIPELINE_AUTHENTICATOR
static final String	PIPELINE_AUTHORIZER
static final String	PIPELINE_HTTP_AGGREGATOR
protected static final String	PIPELINE_HTTP_REQUEST_DECODER
static final String	PIPELINE_HTTP_RESPONSE_ENCODER
static final String	PIPELINE_HTTP_USER_AGENT_HANDLER
static final String	PIPELINE_REQUEST_HANDLER
protected static final String	PIPELINE_SSL
protected ScheduledExecutorService	scheduledExecutorService
protected final Map<String,MessageSerializer<?>>	serializers
protected Settings	settings
protected Optional<io.netty.handler.ssl.SslContext>	sslContext

Constructor Summary

Constructors

Constructor	Description
AbstractChannelizer()

Method Summary

Modifier and Type	Method	Description
abstract void	configure(io.netty.channel.ChannelPipeline pipeline)	This method is called from within initChannel(SocketChannel) just after the SSL handler is put in the pipeline.
protected AbstractAuthenticationHandler	createAuthenticationHandler(Settings settings)
void	init(ServerGremlinExecutor serverGremlinExecutor)	This method is called just after the Channelizer is initialized.
void	initChannel(io.netty.channel.socket.SocketChannel ch)	It is best not to override this method as it sets up some core parts to the server.

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 io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

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

createIdleDetectionMessage, supportsIdleMonitor

Field Details

DEFAULT_SERIALIZERS

protected static final List<Settings.SerializerSettings> DEFAULT_SERIALIZERS

settings

protected Settings settings

gremlinExecutor

protected GremlinExecutor gremlinExecutor

sslContext

protected Optional<io.netty.handler.ssl.SslContext> sslContext

graphManager

protected GraphManager graphManager

gremlinExecutorService

protected ExecutorService gremlinExecutorService

scheduledExecutorService

protected ScheduledExecutorService scheduledExecutorService

PIPELINE_AUTHENTICATOR

public static final String PIPELINE_AUTHENTICATOR

See Also:

• Constant Field Values

PIPELINE_AUTHORIZER

public static final String PIPELINE_AUTHORIZER

See Also:

• Constant Field Values

PIPELINE_REQUEST_HANDLER

public static final String PIPELINE_REQUEST_HANDLER

See Also:

• Constant Field Values

PIPELINE_HTTP_RESPONSE_ENCODER

public static final String PIPELINE_HTTP_RESPONSE_ENCODER

See Also:

• Constant Field Values

PIPELINE_HTTP_AGGREGATOR

public static final String PIPELINE_HTTP_AGGREGATOR

See Also:

• Constant Field Values

PIPELINE_HTTP_USER_AGENT_HANDLER

public static final String PIPELINE_HTTP_USER_AGENT_HANDLER

See Also:

• Constant Field Values

PIPELINE_SSL

protected static final String PIPELINE_SSL

See Also:

• Constant Field Values

PIPELINE_HTTP_REQUEST_DECODER

protected static final String PIPELINE_HTTP_REQUEST_DECODER

See Also:

• Constant Field Values

GREMLIN_ENDPOINT

protected static final String GREMLIN_ENDPOINT

See Also:

• Constant Field Values

serializers

protected final Map<String,MessageSerializer<?>> serializers

channels

protected io.netty.channel.group.ChannelGroup channels

authenticator

protected Authenticator authenticator

authorizer

protected Authorizer authorizer

Constructor Details

AbstractChannelizer

public AbstractChannelizer()

Method Details

configure

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

This method is called from within initChannel(SocketChannel) just after the SSL handler is put in the pipeline. Modify the pipeline as needed here.

init

public void init(ServerGremlinExecutor serverGremlinExecutor)

Description copied from interface: Channelizer

This method is called just after the Channelizer is initialized.

Specified by:

init in interface Channelizer

initChannel

public void initChannel(io.netty.channel.socket.SocketChannel ch)
                 throws Exception

It is best not to override this method as it sets up some core parts to the server. Prefer implementing the configure(ChannelPipeline) methods to alter the pipeline.

Specified by:

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

Throws:

Exception

createAuthenticationHandler

protected AbstractAuthenticationHandler createAuthenticationHandler(Settings settings)