com.buabook.kdb.consumer

Class KdbConsumerThread

java.lang.Object

java.lang.Thread

com.buabook.kdb.consumer.KdbConsumerThread

All Implemented Interfaces:

Runnable

public class KdbConsumerThread
extends Thread

KDB Consumer Thread

Wraps KdbConsumer in a separate thread

(c) 2014 - 2015 Sport Trades Ltd

Since:

3 May 2014

Version:

1.0.1

Author:

Jas Rajasansir

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private KdbConsumer	consumer The underlying consumer object that will listen and notify listeners when messages are received
private IKdbConsumerFailedListener	failureListener
private static org.slf4j.Logger	log

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
KdbConsumerThread(KdbProcess server, KdbDict subscriptionConfig, IKdbRawDataConsumer rawDataConsumer, IKdbTableConsumer tableConsumer, IKdbConsumerFailedListener failureListener)
KdbConsumerThread(KdbProcess server, List<String> tables, IKdbRawDataConsumer rawDataConsumer, IKdbTableConsumer tableConsumer, IKdbConsumerFailedListener failureListener) NOTE: At least one of IKdbRawDataConsumer or IKdbTableConsumer must be supplied.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

consumer

private KdbConsumer consumer

The underlying consumer object that will listen and notify listeners when messages are received

failureListener

private IKdbConsumerFailedListener failureListener

Constructor Detail

KdbConsumerThread

public KdbConsumerThread(KdbProcess server,
                         List<String> tables,
                         IKdbRawDataConsumer rawDataConsumer,
                         IKdbTableConsumer tableConsumer,
                         IKdbConsumerFailedListener failureListener)
                  throws KdbTargetProcessUnavailableException

NOTE: At least one of IKdbRawDataConsumer or IKdbTableConsumer must be supplied. Both can also be supplied.

NOTE 2: If a failure listener (IKdbConsumerFailedListener) is supplied and the connection to the kdb process fails, this will be handled before the exception is thrown.

Parameters:

server - The server to connect and subscribe to

tables - The list of tables to subscribe to

rawDataConsumer - Optional class to consume the raw Object's that are received from kdb. Pass null for no consumer

tableConsumer - Optional class to consume nicer KdbTable's as received from kdb. Pass null for no consumer

failureListener - Optional class to be notified if the consumer fails to start up or subscribe. Pass null for no listener

Throws:

KdbTargetProcessUnavailableException

See Also:

KdbConsumer.KdbConsumer(KdbProcess, List, IKdbRawDataConsumer, IKdbTableConsumer)

KdbConsumerThread

public KdbConsumerThread(KdbProcess server,
                         KdbDict subscriptionConfig,
                         IKdbRawDataConsumer rawDataConsumer,
                         IKdbTableConsumer tableConsumer,
                         IKdbConsumerFailedListener failureListener)
                  throws KdbTargetProcessUnavailableException

Throws:

KdbTargetProcessUnavailableException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread