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).
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 Graphs |
graphs |
protected GremlinExecutor |
gremlinExecutor |
protected ExecutorService |
gremlinExecutorService |
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<SSLEngine> |
sslEngine |
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(Settings settings,
GremlinExecutor gremlinExecutor,
ExecutorService gremlinExecutorService,
Graphs graphs,
ScheduledExecutorService scheduledExecutorService)
This method is called just after the
Channelizer is initialized. |
void |
initChannel(SocketChannel ch) |
protected Settings settings
protected GremlinExecutor gremlinExecutor
protected Graphs graphs
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 final Map<String,MessageSerializer> serializers
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(Settings settings, GremlinExecutor gremlinExecutor, ExecutorService gremlinExecutorService, Graphs graphs, ScheduledExecutorService scheduledExecutorService)
Channelizer
Channelizer
is initialized.init
in interface Channelizer
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.