public static final class Channelizer.WebSocketChannelizer extends Channelizer.AbstractChannelizer
Channelizer
implementation.Channelizer.AbstractChannelizer, Channelizer.NioChannelizer, Channelizer.WebSocketChannelizer
cluster, connection, PIPELINE_GREMLIN_HANDLER, PIPELINE_GREMLIN_SASL_HANDLER
Constructor and Description |
---|
WebSocketChannelizer() |
Modifier and Type | Method and Description |
---|---|
void |
close(io.netty.channel.Channel channel)
Sends a
CloseWebSocketFrame to the server for the specified channel. |
void |
configure(io.netty.channel.ChannelPipeline pipeline) |
void |
connected()
Called after the channel connects.
|
Object |
createKeepAliveMessage()
Deprecated.
As of release 3.4.9, not directly replaced. The keep-alive functionality is delegated to Netty
IdleStateHandler which is added to the pipeline in Channelizer . |
void |
init(org.apache.tinkerpop.gremlin.driver.Connection connection)
Initializes the
Channelizer . |
boolean |
supportsKeepAlive()
Deprecated.
As of release 3.4.9, not directly replaced. The keep-alive functionality is delegated to Netty
IdleStateHandler which is added to the pipeline in Channelizer . |
boolean |
supportsSsl() |
finalize, initChannel
channelRegistered, exceptionCaught, handlerAdded, handlerRemoved
channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered
public void init(org.apache.tinkerpop.gremlin.driver.Connection connection)
Channelizer
Channelizer
. Called just after construction.init
in interface Channelizer
init
in class Channelizer.AbstractChannelizer
@Deprecated public boolean supportsKeepAlive()
IdleStateHandler
which is added to the pipeline in Channelizer
.@Deprecated public Object createKeepAliveMessage()
IdleStateHandler
which is added to the pipeline in Channelizer
.Channelizer
Channelizer.supportsKeepAlive()
is true
.public void close(io.netty.channel.Channel channel)
CloseWebSocketFrame
to the server for the specified channel.close
in interface Channelizer
close
in class Channelizer.AbstractChannelizer
public boolean supportsSsl()
supportsSsl
in class Channelizer.AbstractChannelizer
public void configure(io.netty.channel.ChannelPipeline pipeline)
configure
in class Channelizer.AbstractChannelizer
public void connected()
Channelizer
Channelizer
may need to perform some functions, such as a
handshake.Copyright © 2013–2021 Apache Software Foundation. All rights reserved.