Package org.apache.tinkerpop.gremlin.driver

Class Channelizer.AbstractChannelizer

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, Channelizer
    Direct Known Subclasses:
    Channelizer.WebSocketChannelizer
    Enclosing interface:
    Channelizer
    public abstract static class Channelizer.AbstractChannelizer
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>
implements Channelizer
    Base implementation of the client side Channelizer.

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      void close​(io.netty.channel.Channel channel)
      Called on Connection.closeAsync() to perform an Channelizer specific functions.
      abstract void configure​(io.netty.channel.ChannelPipeline pipeline)  
      void finalize​(io.netty.channel.ChannelPipeline pipeline)  
      void init​(org.apache.tinkerpop.gremlin.driver.Connection connection)
      Initializes the Channelizer.
      protected void initChannel​(io.netty.channel.socket.SocketChannel socketChannel)  
      boolean supportsSsl()  

      • 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 interface io.netty.channel.ChannelHandler

        handlerAdded, handlerRemoved

    • Constructor Detail

      • AbstractChannelizer

        public AbstractChannelizer()

    • Method Detail

      • supportsSsl

        public boolean supportsSsl()

      • configure

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

      • finalize

        public void finalize​(io.netty.channel.ChannelPipeline pipeline)

      • close

        public void close​(io.netty.channel.Channel channel)
        Description copied from interface: Channelizer
        Called on Connection.closeAsync() to perform an Channelizer specific functions. Note that the Connection already calls Channel.close() so there is no need to call that method here. An implementation will typically use this method to send a Channelizer specific message to the server to notify of shutdown coming from the client side (e.g. a "close" websocket frame).
        Specified by:
        close in interface Channelizer

      • 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

      • initChannel

        protected void initChannel​(io.netty.channel.socket.SocketChannel socketChannel)
                    throws Exception
        Specified by:
        initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>
        Throws:
        Exception