com.datasift.client.stream

Class StreamingData

java.lang.Object

com.datasift.client.stream.StreamingData

All Implemented Interfaces:

io.higgs.ws.client.WebSocketEventListener

public class StreamingData
extends Object
implements io.higgs.ws.client.WebSocketEventListener

Author:

Courtney Robinson

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSiftConfig	config
protected boolean	connected
static int	CONNECTION_TIMEOUT
static int	CONNECTION_TIMEOUT_LIMIT
protected short	currentTimeout
static boolean	detectDeadConnection
protected URI	endpoint
protected ErrorListener	errorListener
protected org.joda.time.DateTime	lastSeen
protected io.higgs.ws.client.WebSocketStream	liveStream
protected org.slf4j.Logger	log
protected short	MAX_TIMEOUT
protected StreamEventListener	streamEventListener
protected static Set<StreamingData>	streams
protected Map<Stream,StreamSubscription>	subscriptions
protected Set<StreamSubscription>	unsentSubscriptions

Constructor Summary

Constructors

Constructor and Description
StreamingData(DataSiftConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	connect()
protected void	fireError(Throwable e)
protected void	fireInteraction(String hash, Interaction interaction)
protected void	fireMessage(DataSiftMessage message)
void	onClose(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.websocketx.CloseWebSocketFrame frame)
void	onConnect(io.netty.channel.ChannelHandlerContext ctx)
void	onError(io.netty.channel.ChannelHandlerContext ctx, Throwable cause, io.netty.handler.codec.http.FullHttpResponse response)
StreamingData	onError(ErrorListener listener) Subscribes a callback to listen for exceptions that may occur during streaming.
void	onMessage(io.netty.channel.ChannelHandlerContext ctx, io.higgs.ws.client.WebSocketMessage msg)
void	onPing(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame)
void	onStreamEvent(StreamEventListener streamEventListener)
protected void	pushUnsentSubscriptions()
StreamingData	subscribe(StreamSubscription subscription)
StreamingData	unsubscribe(Stream stream)

Methods inherited from class java.lang.Object

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

Field Detail

endpoint

protected URI endpoint

liveStream

protected io.higgs.ws.client.WebSocketStream liveStream

config

protected DataSiftConfig config

subscriptions

protected Map<Stream,StreamSubscription> subscriptions

errorListener

protected ErrorListener errorListener

streamEventListener

protected StreamEventListener streamEventListener

connected

protected boolean connected

unsentSubscriptions

protected Set<StreamSubscription> unsentSubscriptions

MAX_TIMEOUT

protected short MAX_TIMEOUT

currentTimeout

protected short currentTimeout

lastSeen

protected org.joda.time.DateTime lastSeen

streams

protected static Set<StreamingData> streams

detectDeadConnection

public static boolean detectDeadConnection

CONNECTION_TIMEOUT_LIMIT

public static int CONNECTION_TIMEOUT_LIMIT

CONNECTION_TIMEOUT

public static int CONNECTION_TIMEOUT

log

protected org.slf4j.Logger log

Constructor Detail

StreamingData

public StreamingData(DataSiftConfig config)

Method Detail

onConnect

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

Specified by:

onConnect in interface io.higgs.ws.client.WebSocketEventListener

onClose

public void onClose(io.netty.channel.ChannelHandlerContext ctx,
           io.netty.handler.codec.http.websocketx.CloseWebSocketFrame frame)

Specified by:

onClose in interface io.higgs.ws.client.WebSocketEventListener

onPing

public void onPing(io.netty.channel.ChannelHandlerContext ctx,
          io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame)

Specified by:

onPing in interface io.higgs.ws.client.WebSocketEventListener

onMessage

public void onMessage(io.netty.channel.ChannelHandlerContext ctx,
             io.higgs.ws.client.WebSocketMessage msg)

Specified by:

onMessage in interface io.higgs.ws.client.WebSocketEventListener

onError

public void onError(io.netty.channel.ChannelHandlerContext ctx,
           Throwable cause,
           io.netty.handler.codec.http.FullHttpResponse response)

Specified by:

onError in interface io.higgs.ws.client.WebSocketEventListener

connect

protected void connect()

fireInteraction

protected void fireInteraction(String hash,
                   Interaction interaction)

fireMessage

protected void fireMessage(DataSiftMessage message)

fireError

protected void fireError(Throwable e)

onError

public StreamingData onError(ErrorListener listener)

Subscribes a callback to listen for exceptions that may occur during streaming. When exceptions occur it is unlikely we'll know which stream/subscription caused the exception so instead of notifying all stream subscribers of the same exception this provides a way to list the error just once

Parameters:

listener - an error callback

onStreamEvent

public void onStreamEvent(StreamEventListener streamEventListener)

subscribe

public StreamingData subscribe(StreamSubscription subscription)

pushUnsentSubscriptions

protected void pushUnsentSubscriptions()

unsubscribe

public StreamingData unsubscribe(Stream stream)