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() |
String |
getDefaultContentType() |
int |
getPort() |
String |
getSubscriberPath() |
org.apache.synapse.MessageContext |
getSynapseMessageContext(String tenantDomain) |
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,
org.apache.synapse.MessageContext synCtx) |
protected void |
handleWebsocketPassthroughTextFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame,
org.apache.synapse.MessageContext synCtx) |
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
ensureNotSharable, handlerRemoved, isSharable
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) throws Exception
channelInactive
in interface io.netty.channel.ChannelInboundHandler
channelInactive
in class io.netty.channel.ChannelInboundHandlerAdapter
Exception
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, org.apache.synapse.MessageContext synCtx) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
protected void handleWebsocketPassthroughTextFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame, org.apache.synapse.MessageContext synCtx) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public InboundWebsocketChannelContext getChannelHandlerContext()
public String getSubscriberPath()
public int getClientBroadcastLevel()
public String getDefaultContentType()
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 org.apache.synapse.MessageContext getSynapseMessageContext(String tenantDomain) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
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 © 2020 WSO2. All rights reserved.