Class WebSocketClientHandler
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.SimpleChannelInboundHandler<Object>
-
- org.wso2.carbon.websocket.transport.WebSocketClientHandler
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
public class WebSocketClientHandler extends io.netty.channel.SimpleChannelInboundHandler<Object>
-
-
Constructor Summary
Constructors Constructor Description WebSocketClientHandler(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
acknowledgeHandshake()
void
channelActive(io.netty.channel.ChannelHandlerContext ctx)
void
channelInactive(io.netty.channel.ChannelHandlerContext ctx)
protected void
channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
Map<String,Object>
getApiProperties()
io.netty.channel.ChannelHandlerContext
getChannelHandlerContext()
String
getCorrelationId()
void
handleHandshake(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.FullHttpResponse msg)
void
handlePassthroughTextFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
void
handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void
handleTargetWebsocketChannelTermination(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
void
handleWebsocketBinaryFrame(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
void
handleWebSocketFrame(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
io.netty.channel.ChannelFuture
handshakeFuture()
void
registerWebsocketResponseSender(org.apache.synapse.inbound.InboundResponseSender responseSender)
void
setApiProperties(Map<String,Object> apiProperties)
void
setCorrelationId(String correlationId)
void
setDispatchErrorSequence(String dispatchErrorSequence)
void
setDispatchSequence(String dispatchSequence)
void
setTenantDomain(String tenantDomain)
void
userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
-
Methods inherited from class io.netty.channel.SimpleChannelInboundHandler
acceptInboundMessage, channelRead
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerRemoved, isSharable
-
-
-
-
Method Detail
-
getCorrelationId
public String getCorrelationId()
-
setCorrelationId
public void setCorrelationId(String correlationId)
-
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 interfaceio.netty.channel.ChannelHandler
- Overrides:
handlerAdded
in classio.netty.channel.ChannelHandlerAdapter
-
channelActive
public void channelActive(io.netty.channel.ChannelHandlerContext ctx)
- Specified by:
channelActive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelActive
in classio.netty.channel.ChannelInboundHandlerAdapter
-
userEventTriggered
public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt) throws Exception
- Specified by:
userEventTriggered
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
userEventTriggered
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-
channelInactive
public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)
- Specified by:
channelInactive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelInactive
in classio.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
-
exceptionCaught
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause) throws org.apache.axis2.AxisFault
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
exceptionCaught
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
org.apache.axis2.AxisFault
-
-