Interface Channelizer
-
- All Superinterfaces:
io.netty.channel.ChannelHandler
- All Known Implementing Classes:
Channelizer.AbstractChannelizer
,Channelizer.HttpChannelizer
,Channelizer.WebSocketChannelizer
public interface Channelizer extends io.netty.channel.ChannelHandler
Client-side channel initializer interface. It is responsible for constructing the NettyChannelPipeline
used by the client to connect and send message to Gremlin Server.- Author:
- Stephen Mallette (http://stephen.genoprime.com)
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
Channelizer.AbstractChannelizer
Base implementation of the client sideChannelizer
.static class
Channelizer.HttpChannelizer
Sends requests over the HTTP endpoint.static class
Channelizer.WebSocketChannelizer
WebSocketChannelizer
implementation.
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
close(io.netty.channel.Channel channel)
Called onConnection.closeAsync()
to perform anChannelizer
specific functions.default void
connected()
Called after the channel connects.default String
getScheme(boolean sslEnabled)
Gets the scheme to use to construct the URL and by default uses HTTP.void
init(org.apache.tinkerpop.gremlin.driver.Connection connection)
Initializes theChannelizer
.
-
-
-
Method Detail
-
init
void init(org.apache.tinkerpop.gremlin.driver.Connection connection)
Initializes theChannelizer
. Called just after construction.
-
close
void close(io.netty.channel.Channel channel)
Called onConnection.closeAsync()
to perform anChannelizer
specific functions. Note that theConnection
already callsChannel.close()
so there is no need to call that method here. An implementation will typically use this method to send aChannelizer
specific message to the server to notify of shutdown coming from the client side (e.g. a "close" websocket frame).
-
connected
default void connected()
Called after the channel connects. TheChannelizer
may need to perform some functions, such as a handshake.
-
getScheme
default String getScheme(boolean sslEnabled)
Gets the scheme to use to construct the URL and by default uses HTTP.
-
-