com.datasift.client.stream

Class ConnectionManager

java.lang.Object

com.datasift.client.stream.ConnectionManager

public class ConnectionManager
extends java.lang.Object

Author:

Courtney Robinson

Field Summary

Fields

Modifier and Type	Field and Description
protected DataSiftConfig	config
protected boolean	connected
protected static boolean	CONNECTION_DETECTOR_RUNNING
static int	CONNECTION_TIMEOUT
static int	CONNECTION_TIMEOUT_LIMIT
static java.util.Set<com.datasift.client.stream.DataSiftConnection>	connections
static boolean	detectDeadConnection
protected java.net.URI	endpoint
protected ErrorListener	errorListener
protected org.slf4j.Logger	log
protected int	MAX_STREAMS_PER_CONNECTION
protected StreamEventListener	streamEventListener

Constructor Summary

Constructors

Constructor and Description
ConnectionManager(DataSiftConfig config)

Method Summary

Modifier and Type	Method and Description
static void	detectDeadConnections() Starts a thread which checks periodically for dead connections and force them to re-connect.
protected com.datasift.client.stream.DataSiftConnection	obtainConnectionFor(Stream stream)
ConnectionManager	onError(ErrorListener listener) Subscribes a callback to listen for exceptions that may occur during streaming.
void	onStreamEvent(StreamEventListener streamEventListener)
ConnectionManager	subscribe(StreamSubscription subscription)
ConnectionManager	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 java.net.URI endpoint

config

protected DataSiftConfig config

errorListener

protected ErrorListener errorListener

streamEventListener

protected StreamEventListener streamEventListener

connected

protected boolean connected

detectDeadConnection

public static boolean detectDeadConnection

CONNECTION_TIMEOUT_LIMIT

public static int CONNECTION_TIMEOUT_LIMIT

CONNECTION_TIMEOUT

public static int CONNECTION_TIMEOUT

CONNECTION_DETECTOR_RUNNING

protected static boolean CONNECTION_DETECTOR_RUNNING

log

protected org.slf4j.Logger log

connections

public static final java.util.Set<com.datasift.client.stream.DataSiftConnection> connections

MAX_STREAMS_PER_CONNECTION

protected final int MAX_STREAMS_PER_CONNECTION

See Also:

Constant Field Values

Constructor Detail

ConnectionManager

public ConnectionManager(DataSiftConfig config)

Method Detail

detectDeadConnections

public static void detectDeadConnections()

Starts a thread which checks periodically for dead connections and force them to re-connect. IF AND ONLY IF a thread isn't already running to do this

obtainConnectionFor

protected com.datasift.client.stream.DataSiftConnection obtainConnectionFor(Stream stream)

onError

public ConnectionManager 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 ConnectionManager subscribe(StreamSubscription subscription)

unsubscribe

public ConnectionManager unsubscribe(Stream stream)