Class WebSocketClientHandler

  • All Implemented Interfaces:
    io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

    public class WebSocketClientHandler
    extends io.netty.channel.SimpleChannelInboundHandler<Object>
    • Constructor Detail

      • WebSocketClientHandler

        public WebSocketClientHandler​(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker)
    • Method Detail

      • getCorrelationId

        public String getCorrelationId()
      • setCorrelationId

        public void setCorrelationId​(String correlationId)
      • setApiProperties

        public void setApiProperties​(Map<String,​Object> apiProperties)
      • setTenantDomain

        public void setTenantDomain​(String tenantDomain)
      • setDispatchSequence

        public void setDispatchSequence​(String dispatchSequence)
      • setDispatchErrorSequence

        public void setDispatchErrorSequence​(String dispatchErrorSequence)
      • handshakeFuture

        public io.netty.channel.ChannelFuture handshakeFuture()
      • getChannelHandlerContext

        public io.netty.channel.ChannelHandlerContext getChannelHandlerContext()
      • registerWebsocketResponseSender

        public void registerWebsocketResponseSender​(org.apache.synapse.inbound.InboundResponseSender responseSender)
      • handlerAdded

        public void handlerAdded​(io.netty.channel.ChannelHandlerContext ctx)
        Specified by:
        handlerAdded in interface io.netty.channel.ChannelHandler
        Overrides:
        handlerAdded in class io.netty.channel.ChannelHandlerAdapter
      • channelActive

        public void channelActive​(io.netty.channel.ChannelHandlerContext ctx)
        Specified by:
        channelActive in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelActive in class io.netty.channel.ChannelInboundHandlerAdapter
      • userEventTriggered

        public void userEventTriggered​(io.netty.channel.ChannelHandlerContext ctx,
                                       Object evt)
                                throws Exception
        Specified by:
        userEventTriggered in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        userEventTriggered in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        Exception
      • channelInactive

        public void channelInactive​(io.netty.channel.ChannelHandlerContext ctx)
        Specified by:
        channelInactive in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter
      • handleHandshake

        public void handleHandshake​(io.netty.channel.ChannelHandlerContext ctx,
                                    io.netty.handler.codec.http.FullHttpResponse msg)
      • acknowledgeHandshake

        public void acknowledgeHandshake()
      • handleTargetWebsocketChannelTermination

        public void handleTargetWebsocketChannelTermination​(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
                                                     throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • handleWebsocketBinaryFrame

        public void handleWebsocketBinaryFrame​(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
                                        throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • handlePassthroughTextFrame

        public void handlePassthroughTextFrame​(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
                                        throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • handleWebSocketFrame

        public void handleWebSocketFrame​(io.netty.channel.ChannelHandlerContext ctx,
                                         io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
                                  throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • channelRead0

        protected void channelRead0​(io.netty.channel.ChannelHandlerContext ctx,
                                    Object msg)
                             throws Exception
        Specified by:
        channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<Object>
        Throws:
        Exception
      • exceptionCaught

        public void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx,
                                    Throwable cause)
                             throws org.apache.axis2.AxisFault
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelHandler
        Specified by:
        exceptionCaught in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        org.apache.axis2.AxisFault