com.buabook.kdb.publisher

Class KdbPublisherThread

java.lang.Object

java.lang.Thread

com.buabook.kdb.publisher.KdbPublisherThread

All Implemented Interfaces:

Runnable

public class KdbPublisherThread
extends Thread

KDB Publisher Thread

(c) 2014 - 2015 Sport Trades Ltd

Since:

17 Apr 2014

Version:

1.0.3

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 static Long	DEFAULT_THREAD_SLEEP_MS Specifies the default time the thread should sleep between cycles
private static org.slf4j.Logger	log
private ConcurrentLinkedQueue<KdbTable>	publishBuffer Buffer for all tables that are to be published on this thread to the KDB process
private KdbPublisher	publisher The publisher class containing the code to publish to the KDB process
private Long	threadSleepMs The time the thread should sleep between cycles

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
KdbPublisherThread(KdbProcess server) Configures the publisher thread with the default thread sleep interval
KdbPublisherThread(KdbProcess server, Long threadSleepMs) Provides a instantiation of a KdbPublisher but wrapped up in this threaded class to allow execution to occur separately from the main thread
KdbPublisherThread(KdbProcess server, Long threadSleepMs, org.joda.time.Duration resetConnectionDuration)
KdbPublisherThread(KdbPublisher publisher, Long threadSleepMs)

Method Summary

Modifier and Type	Method and Description
void	disconnect()
void	publish(KdbTable table)
void	publish(List<KdbTable> tables) This method adds the list of tables to the publish buffer (publishBuffer) ready for publishing to the kdb process on the next iteration of the main thread loop.
void	publish(String tableName, c.Flip tableData)
void	run() Thread sleeps for the specified threadSleepMs before retrieving the latest table from the head of the queue and publishes to the kdb process.

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

DEFAULT_THREAD_SLEEP_MS

private static final Long DEFAULT_THREAD_SLEEP_MS

Specifies the default time the thread should sleep between cycles

threadSleepMs

private final Long threadSleepMs

The time the thread should sleep between cycles

publisher

private KdbPublisher publisher

The publisher class containing the code to publish to the KDB process

publishBuffer

private ConcurrentLinkedQueue<KdbTable> publishBuffer

Buffer for all tables that are to be published on this thread to the KDB process

Constructor Detail

KdbPublisherThread

public KdbPublisherThread(KdbProcess server)
                   throws KdbTargetProcessUnavailableException

Configures the publisher thread with the default thread sleep interval

Throws:

KdbTargetProcessUnavailableException

See Also:

KdbPublisherThread(KdbProcess, Long), DEFAULT_THREAD_SLEEP_MS

KdbPublisherThread

public KdbPublisherThread(KdbProcess server,
                          Long threadSleepMs)
                   throws KdbTargetProcessUnavailableException

Provides a instantiation of a KdbPublisher but wrapped up in this threaded class to allow execution to occur separately from the main thread

Parameters:

server - The KDB process to connect to

threadSleepMs - The time the thread should sleep when there is nothing to publish

Throws:

KdbTargetProcessUnavailableException - If the KDB process is unavailable at instantiation time

See Also:

KdbPublisher.KdbPublisher(KdbProcess)

KdbPublisherThread

public KdbPublisherThread(KdbProcess server,
                          Long threadSleepMs,
                          org.joda.time.Duration resetConnectionDuration)
                   throws KdbTargetProcessUnavailableException

Throws:

KdbTargetProcessUnavailableException

KdbPublisherThread

public KdbPublisherThread(KdbPublisher publisher,
                          Long threadSleepMs)

Method Detail

run

public void run()

Thread sleeps for the specified threadSleepMs before retrieving the latest table from the head of the queue and publishes to the kdb process.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

Thread.sleep(long), KdbConnection.isConnected(), KdbPublisher.publish(KdbTable)

publish

public void publish(List<KdbTable> tables)

This method adds the list of tables to the publish buffer (publishBuffer) ready for publishing to the kdb process on the next iteration of the main thread loop.

NOTE: Do not send lists with null KdbTable elements.

See Also:

ConcurrentLinkedQueue.addAll(java.util.Collection)

publish

public void publish(KdbTable table)

See Also:

KdbPublisher.publish(KdbTable)

publish

public void publish(String tableName,
                    c.Flip tableData)

See Also:

KdbPublisher#publish(String, Flip)

disconnect

public void disconnect()

See Also:

KdbConnection.disconnect()