org.apache.tinkerpop.gremlin.server.channel

Class NioChannelizer

java.lang.Object

<any>

org.apache.tinkerpop.gremlin.server.AbstractChannelizer

org.apache.tinkerpop.gremlin.server.channel.NioChannelizer

All Implemented Interfaces:

Channelizer

public class NioChannelizer
extends AbstractChannelizer

A Channelizer that exposes an NIO-based Gremlin endpoint with a custom protocol.

Author:

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

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.server.AbstractChannelizer

authenticator, DEFAULT_SERIALIZERS, graphManager, gremlinExecutor, gremlinExecutorService, PIPELINE_AUTHENTICATOR, PIPELINE_OP_EXECUTOR, PIPELINE_OP_SELECTOR, PIPELINE_RESULT_ITERATOR_HANDLER, PIPELINE_SSL, scheduledExecutorService, serializers, settings, sslContext

Constructor Summary

Constructors

Constructor and Description
NioChannelizer()

Method Summary

Modifier and Type	Method and Description
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	init(ServerGremlinExecutor<EventLoopGroup> serverGremlinExecutor) This method is called just after the Channelizer is initialized.

Methods inherited from class org.apache.tinkerpop.gremlin.server.AbstractChannelizer

finalize, initChannel

Methods inherited from class java.lang.Object

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

Constructor Detail

NioChannelizer

public NioChannelizer()

Method Detail

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

Overrides:

init in class AbstractChannelizer

configure

public void configure(ChannelPipeline pipeline)

Description copied from class: AbstractChannelizer

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.

Specified by:

configure in class AbstractChannelizer