public class InboundWebsocketSourceHandler
extends io.netty.channel.ChannelInboundHandlerAdapter
Constructor and Description |
---|
InboundWebsocketSourceHandler() |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(io.netty.channel.ChannelHandlerContext ctx) |
void |
channelInactive(io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
InboundWebsocketChannelContext |
getChannelHandlerContext() |
int |
getClientBroadcastLevel() |
int |
getPort() |
String |
getSubscriberPath() |
String |
getTenantDomain() |
void |
handleClientWebsocketChannelTermination(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) |
protected void |
handleException(String msg) |
void |
handlerAdded(io.netty.channel.ChannelHandlerContext ctx) |
protected void |
handleWebsocketBinaryFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) |
protected void |
handleWebsocketPassthroughTextFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) |
void |
setClientBroadcastLevel(int clientBroadcastLevel) |
void |
setDispatchToCustomSequence(boolean dispatchToCustomSequence) |
void |
setOutflowDispatchSequence(String outflowDispatchSequence) |
void |
setOutflowErrorSequence(String outflowErrorSequence) |
void |
setPortOffset(int portOffset) |
void |
setSubprotocolHandlers(ArrayList<AbstractSubprotocolHandler> subprotocolHandlers) |
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
public void setSubprotocolHandlers(ArrayList<AbstractSubprotocolHandler> subprotocolHandlers)
public void channelActive(io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelActive
in interface io.netty.channel.ChannelInboundHandler
channelActive
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
handlerAdded
in interface io.netty.channel.ChannelHandler
handlerAdded
in class io.netty.channel.ChannelHandlerAdapter
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
channelRead
in interface io.netty.channel.ChannelInboundHandler
channelRead
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
channelInactive
in interface io.netty.channel.ChannelInboundHandler
channelInactive
in class io.netty.channel.ChannelInboundHandlerAdapter
public void handleClientWebsocketChannelTermination(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
protected void handleWebsocketBinaryFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
protected void handleWebsocketPassthroughTextFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public InboundWebsocketChannelContext getChannelHandlerContext()
public String getSubscriberPath()
public int getClientBroadcastLevel()
public void setOutflowDispatchSequence(String outflowDispatchSequence)
public void setOutflowErrorSequence(String outflowErrorSequence)
public void setClientBroadcastLevel(int clientBroadcastLevel)
protected void handleException(String msg)
public int getPort()
public String getTenantDomain()
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
exceptionCaught
in interface io.netty.channel.ChannelHandler
exceptionCaught
in interface io.netty.channel.ChannelInboundHandler
exceptionCaught
in class io.netty.channel.ChannelInboundHandlerAdapter
public void setDispatchToCustomSequence(boolean dispatchToCustomSequence)
public void setPortOffset(int portOffset)
Copyright © 2017 WSO2. All rights reserved.