Package org.apache.tinkerpop.gremlin.driver

Class Channelizer.HttpChannelizer

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

org.apache.tinkerpop.gremlin.driver.Channelizer.AbstractChannelizer

org.apache.tinkerpop.gremlin.driver.Channelizer.HttpChannelizer

All Implemented Interfaces:

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

Enclosing interface:

Channelizer

public static final class Channelizer.HttpChannelizer
extends Channelizer.AbstractChannelizer

Sends requests over the HTTP endpoint. Client functionality is governed by the limitations of the HTTP endpoint, meaning that sessions are not available and as such tx() (i.e. transactions) are not available over this channelizer. Only sessionless requests are possible.

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.driver.Channelizer

Channelizer.AbstractChannelizer, Channelizer.HttpChannelizer

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.tinkerpop.gremlin.util.message.ResponseMessage	LAST_CONTENT_READ_RESPONSE	This response is used as a signal for determining if all content of the response has been read.

Fields inherited from class org.apache.tinkerpop.gremlin.driver.Channelizer.AbstractChannelizer

cluster, connection, PIPELINE_GREMLIN_HANDLER, PIPELINE_HTTP_AGGREGATOR, PIPELINE_HTTP_CODEC, PIPELINE_HTTP_DECODER, PIPELINE_HTTP_DECOMPRESSION_HANDLER, PIPELINE_HTTP_ENCODER, PIPELINE_IDLE_CONNECTION_HANDLER, PIPELINE_IDLE_STATE_HANDLER, PIPELINE_SSL_HANDLER, sslHandler

Constructor Summary

Constructors

Constructor	Description
HttpChannelizer()

Method Summary

Modifier and Type	Method	Description
void	configure(io.netty.channel.ChannelPipeline pipeline)
void	connected()	Called after the channel connects.
void	init(org.apache.tinkerpop.gremlin.driver.Connection connection)	Initializes the Channelizer.
boolean	supportsSsl()

Methods inherited from class org.apache.tinkerpop.gremlin.driver.Channelizer.AbstractChannelizer

close, finalize, initChannel

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.driver.Channelizer

getScheme

Field Detail

LAST_CONTENT_READ_RESPONSE

public static final org.apache.tinkerpop.gremlin.util.message.ResponseMessage LAST_CONTENT_READ_RESPONSE

This response is used as a signal for determining if all content of the response has been read.

Constructor Detail

HttpChannelizer

public HttpChannelizer()

Method Detail

init

public void init(org.apache.tinkerpop.gremlin.driver.Connection connection)

Description copied from interface: Channelizer

Initializes the Channelizer. Called just after construction.

Specified by:

init in interface Channelizer

Overrides:

init in class Channelizer.AbstractChannelizer

connected

public void connected()

Description copied from interface: Channelizer

Called after the channel connects. The Channelizer may need to perform some functions, such as a handshake.

Specified by:

connected in interface Channelizer

Overrides:

connected in class Channelizer.AbstractChannelizer

supportsSsl

public boolean supportsSsl()

Overrides:

supportsSsl in class Channelizer.AbstractChannelizer

configure

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

Specified by:

configure in class Channelizer.AbstractChannelizer