org.apache.tinkerpop.gremlin.server

Class AbstractChannelizer

java.lang.Object

<any>

org.apache.tinkerpop.gremlin.server.AbstractChannelizer

All Implemented Interfaces:

Channelizer

Direct Known Subclasses:

HttpChannelizer, NioChannelizer, WebSocketChannelizer

public abstract class AbstractChannelizer
extends <any>
implements Channelizer

A base implementation for the Channelizer which does a basic configuration of the 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)

Field Summary

Fields

Modifier and Type	Field and Description
protected Authenticator	authenticator
protected GraphManager	graphManager
protected GremlinExecutor	gremlinExecutor
protected ExecutorService	gremlinExecutorService
protected static String	PIPELINE_AUTHENTICATOR
protected static String	PIPELINE_OP_EXECUTOR
protected static String	PIPELINE_OP_SELECTOR
protected static String	PIPELINE_RESULT_ITERATOR_HANDLER
protected static String	PIPELINE_SSL
protected ScheduledExecutorService	scheduledExecutorService
protected Map<String,MessageSerializer>	serializers
protected Settings	settings
protected Optional<SslContext>	sslContext

Constructor Summary

Constructors

Constructor and Description
AbstractChannelizer()

Method Summary

Modifier and Type	Method and Description
abstract void	configure(ChannelPipeline pipeline) This method is called from within #initChannel(io.netty.channel.socket.SocketChannel) just after the SSL handler is put in the pipeline.
void	finalize(ChannelPipeline pipeline) This method is called after the pipeline is completely configured.
void	init(ServerGremlinExecutor<EventLoopGroup> serverGremlinExecutor) This method is called just after the Channelizer is initialized.
void	initChannel(SocketChannel ch)

Methods inherited from class java.lang.Object

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

Field Detail

settings

protected Settings settings

gremlinExecutor

protected GremlinExecutor gremlinExecutor

sslContext

protected Optional<SslContext> sslContext

graphManager

protected GraphManager graphManager

gremlinExecutorService

protected ExecutorService gremlinExecutorService

scheduledExecutorService

protected ScheduledExecutorService scheduledExecutorService

PIPELINE_SSL

protected static final String PIPELINE_SSL

See Also:

Constant Field Values

PIPELINE_OP_SELECTOR

protected static final String PIPELINE_OP_SELECTOR

See Also:

Constant Field Values

PIPELINE_RESULT_ITERATOR_HANDLER

protected static final String PIPELINE_RESULT_ITERATOR_HANDLER

See Also:

Constant Field Values

PIPELINE_OP_EXECUTOR

protected static final String PIPELINE_OP_EXECUTOR

See Also:

Constant Field Values

PIPELINE_AUTHENTICATOR

protected static final String PIPELINE_AUTHENTICATOR

See Also:

Constant Field Values

serializers

protected final Map<String,MessageSerializer> serializers

authenticator

protected Authenticator authenticator

Constructor Detail

AbstractChannelizer

public AbstractChannelizer()

Method Detail

configure

public abstract void configure(ChannelPipeline pipeline)

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

finalize

public void finalize(ChannelPipeline pipeline)

This method is called after the pipeline is completely configured. It can be overridden to make any final changes to the pipeline before it goes into use.

init

public void init(ServerGremlinExecutor<EventLoopGroup> 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(SocketChannel ch)
                 throws Exception

Throws:

Exception