Class InboundWebsocketSourceHandler

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

    public class InboundWebsocketSourceHandler
    extends io.netty.channel.ChannelInboundHandlerAdapter
    • Constructor Detail

      • InboundWebsocketSourceHandler

        public InboundWebsocketSourceHandler()
                                      throws Exception
        Throws:
        Exception
    • Method Detail

      • channelActive

        public void channelActive​(io.netty.channel.ChannelHandlerContext ctx)
                           throws Exception
        Specified by:
        channelActive in interface io.netty.channel.ChannelInboundHandler
        Overrides:
        channelActive in class io.netty.channel.ChannelInboundHandlerAdapter
        Throws:
        Exception
      • 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
      • channelRead

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

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

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

        protected void handleWebsocketBinaryFrame​(io.netty.handler.codec.http.websocketx.WebSocketFrame frame,
                                                  org.apache.synapse.MessageContext synCtx)
                                           throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • handleWebsocketPassthroughTextFrame

        protected void handleWebsocketPassthroughTextFrame​(io.netty.handler.codec.http.websocketx.WebSocketFrame frame,
                                                           org.apache.synapse.MessageContext synCtx)
                                                    throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • getSubscriber

        public URI getSubscriber()
      • getSubscriberPath

        public String getSubscriberPath()
      • getClientBroadcastLevel

        public int getClientBroadcastLevel()
      • getDefaultContentType

        public String getDefaultContentType()
      • setOutflowDispatchSequence

        public void setOutflowDispatchSequence​(String outflowDispatchSequence)
      • setOutflowErrorSequence

        public void setOutflowErrorSequence​(String outflowErrorSequence)
      • setClientBroadcastLevel

        public void setClientBroadcastLevel​(int clientBroadcastLevel)
      • handleException

        protected void handleException​(String msg)
      • getPort

        public int getPort()
      • getTenantDomain

        public String getTenantDomain()
      • getSynapseMessageContext

        public org.apache.synapse.MessageContext getSynapseMessageContext​(String tenantDomain)
                                                                   throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • exceptionCaught

        public void exceptionCaught​(io.netty.channel.ChannelHandlerContext ctx,
                                    Throwable cause)
        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
      • setDispatchToCustomSequence

        public void setDispatchToCustomSequence​(boolean dispatchToCustomSequence)
      • setPortOffset

        public void setPortOffset​(int portOffset)
      • setPassThroughControlFrames

        public void setPassThroughControlFrames​(boolean passThroughControlFrames)
      • getPassThroughControlFrames

        public boolean getPassThroughControlFrames()