info.bitrich.xchangestream.lgo

Class LgoStreamingService

java.lang.Object

info.bitrich.xchangestream.service.ConnectableService

info.bitrich.xchangestream.service.netty.NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

info.bitrich.xchangestream.service.netty.JsonNettyStreamingService

info.bitrich.xchangestream.lgo.LgoStreamingService

public class LgoStreamingService
extends JsonNettyStreamingService

Nested Class Summary

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

NettyStreamingService.NettyWebSocketClientHandler

Field Summary

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

objectMapper

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

channels, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_IDLE_TIMEOUT, DEFAULT_RETRY_DURATION

Fields inherited from class info.bitrich.xchangestream.service.ConnectableService

BEFORE_CONNECTION_HANDLER

Method Summary

Modifier and Type	Method and Description
protected String	getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)
protected io.netty.handler.codec.http.DefaultHttpHeaders	getCustomHeaders()
String	getSubscribeMessage(String channelName, Object... args)
String	getUnsubscribeMessage(String channelName)
protected void	handleIdle(io.netty.channel.ChannelHandlerContext ctx)

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

messageHandler, processArrayMassageSeparately, sendObjectMessage

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

disconnect, getChannel, getSubscriptionUniqueId, getWebSocketClientExtensionHandler, getWebSocketClientHandler, handleChannelError, handleChannelMessage, handleError, handleMessage, isSocketOpen, openConnection, resubscribeChannels, sendMessage, setAcceptAllCertificates, setEnableLoggingHandler, setLoggingHandlerLevel, setSocksProxyHost, setSocksProxyPort, subscribeChannel, subscribeConnectionSuccess, subscribeIdle, subscribeReconnectFailure, useCompressedMessages

Methods inherited from class info.bitrich.xchangestream.service.ConnectableService

connect, setBeforeConnectionHandler

Methods inherited from class java.lang.Object

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

Method Detail

handleIdle

protected void handleIdle(io.netty.channel.ChannelHandlerContext ctx)

Overrides:

handleIdle in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

getChannelNameFromMessage

protected String getChannelNameFromMessage(com.fasterxml.jackson.databind.JsonNode message)

Specified by:

getChannelNameFromMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

getSubscribeMessage

public String getSubscribeMessage(String channelName,
                                  Object... args)
                           throws IOException

Specified by:

getSubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

getUnsubscribeMessage

public String getUnsubscribeMessage(String channelName)
                             throws IOException

Specified by:

getUnsubscribeMessage in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>

Throws:

IOException

getCustomHeaders

protected io.netty.handler.codec.http.DefaultHttpHeaders getCustomHeaders()

Overrides:

getCustomHeaders in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>