public abstract class AbstractChannelizer extends <any> implements Channelizer
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.| 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 and Description |
|---|
AbstractChannelizer() |
| 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) |
protected Settings settings
protected GremlinExecutor gremlinExecutor
protected Optional<SslContext> sslContext
protected GraphManager graphManager
protected ExecutorService gremlinExecutorService
protected ScheduledExecutorService scheduledExecutorService
protected static final String PIPELINE_SSL
protected static final String PIPELINE_OP_SELECTOR
protected static final String PIPELINE_RESULT_ITERATOR_HANDLER
protected static final String PIPELINE_OP_EXECUTOR
protected static final String PIPELINE_AUTHENTICATOR
protected final Map<String,MessageSerializer> serializers
protected Authenticator authenticator
public abstract void configure(ChannelPipeline pipeline)
#initChannel(io.netty.channel.socket.SocketChannel) just after
the SSL handler is put in the pipeline. Modify the pipeline as needed here.public void finalize(ChannelPipeline pipeline)
public void init(ServerGremlinExecutor<EventLoopGroup> serverGremlinExecutor)
ChannelizerChannelizer is initialized.init in interface ChannelizerCopyright © 2013–2015 Apache Software Foundation. All rights reserved.