Package info.bitrich.xchangestream.okcoin

Class OkCoinStreamingService.OkCoinNettyWebSocketClientHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<Object>

info.bitrich.xchangestream.service.netty.WebSocketClientHandler

NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>.NettyWebSocketClientHandler

info.bitrich.xchangestream.okcoin.OkCoinStreamingService.OkCoinNettyWebSocketClientHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Enclosing class:

OkCoinStreamingService

protected class OkCoinStreamingService.OkCoinNettyWebSocketClientHandler
extends NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>.NettyWebSocketClientHandler

Nested Class Summary

Nested classes/interfaces inherited from class info.bitrich.xchangestream.service.netty.WebSocketClientHandler

WebSocketClientHandler.WebSocketMessageHandler

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class info.bitrich.xchangestream.service.netty.WebSocketClientHandler

handler, handshaker

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OkCoinNettyWebSocketClientHandler(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker, WebSocketClientHandler.WebSocketMessageHandler handler)

Method Summary

Modifier and Type	Method	Description
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object msg)

Methods inherited from class info.bitrich.xchangestream.service.netty.NettyStreamingService.NettyWebSocketClientHandler

userEventTriggered

Methods inherited from class info.bitrich.xchangestream.service.netty.WebSocketClientHandler

channelActive, exceptionCaught, handlerAdded, handshakeFuture

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Constructor Details

OkCoinNettyWebSocketClientHandler

protected OkCoinNettyWebSocketClientHandler(io.netty.handler.codec.http.websocketx.WebSocketClientHandshaker handshaker,
 WebSocketClientHandler.WebSocketMessageHandler handler)

Method Details

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>.NettyWebSocketClientHandler

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
 Object msg)
                  throws Exception

Overrides:

channelRead0 in class WebSocketClientHandler

Throws:

Exception