com.datasift.client.stream

Class StreamingData

java.lang.Object

com.datasift.client.stream.StreamingData

public class StreamingData
extends Object

Author:

Courtney Robinson

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSiftConfig	config
protected boolean	connected
protected URI	endpoint
protected ErrorListener	errorListener
protected io.higgs.ws.client.WebSocketStream	liveStream
protected StreamEventListener	streamEventListener
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	fireInteraction(String hash, Interaction interaction)
protected void	fireMessage(DataSiftMessage message)
StreamingData	onError(ErrorListener listener) Subscribes a callback to listen for exceptions that may occur during streaming.
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

Constructor Detail

StreamingData

public StreamingData(DataSiftConfig config)

Method Detail

connect

protected void connect()

fireInteraction

protected void fireInteraction(String hash,
                   Interaction interaction)

fireMessage

protected void fireMessage(DataSiftMessage message)

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 get the error just once

Parameters:

listener - an error callback

Returns:

onStreamEvent

public void onStreamEvent(StreamEventListener streamEventListener)

subscribe

public StreamingData subscribe(StreamSubscription subscription)

pushUnsentSubscriptions

protected void pushUnsentSubscriptions()

unsubscribe

public StreamingData unsubscribe(Stream stream)