Package com.swiftmq.impl.net.netty.scheduler

Class NettyOutboundConnectionHandler

java.lang.Object
ChannelInboundHandlerAdapter
com.swiftmq.impl.net.netty.scheduler.NettyOutboundConnectionHandler
public class NettyOutboundConnectionHandler extends ChannelInboundHandlerAdapter

  • Constructor Details

    • NettyOutboundConnectionHandler

      public NettyOutboundConnectionHandler(SwiftletContext ctx, Connection connection, ConnectionMetaData metaData)

  • Method Details

    • isActive

      public boolean isActive()

    • channelActive

      public void channelActive(ChannelHandlerContext context) throws Exception
      Throws:
      Exception

    • channelInactive

      public void channelInactive(ChannelHandlerContext context) throws Exception
      Throws:
      Exception

    • exceptionCaught

      public void exceptionCaught(ChannelHandlerContext context, Throwable cause) throws Exception
      Throws:
      Exception

    • channelRead

      public void channelRead(ChannelHandlerContext context, Object msg) throws Exception
      Throws:
      Exception

    • performTimeAction

      public void performTimeAction()

    • chunkCompleted

      public void chunkCompleted(byte[] b, int offset, int len)

    • toString

      public String toString()