com.buabook.kdb.publisher

Class KdbPublisherManager

java.lang.Object

com.buabook.kdb.publisher.KdbPublisherManager

public class KdbPublisherManager
extends Object

KDB Publisher Manager

Provides the ability to maintain numerous kdb publishers and interface with them all through a single method call, within this class.

Use cases include PROD & DR dual-publishing

(c) 2014 - 2017 Sport Trades Ltd

Since:

18 Apr 2014

Version:

1.0.2

Author:

Jas Rajasansir

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	log
private ConcurrentHashMap<KdbProcess,KdbPublisherThread>	publishers Map of publishers that are available

Constructor Summary

Constructors

Constructor and Description
KdbPublisherManager()

Method Summary

Modifier and Type	Method and Description
void	addPublisher(KdbProcess server)
void	disconnect(KdbProcess server) Disconnects from the specified kdb server and removes it from the internal management object
List<KdbProcess>	getTargetProcesses()
void	publish(List<KdbProcess> servers, List<KdbTable> tables) Provides the ability to publish a number of KdbTable's to a specified list of kdb processes.
void	publish(List<KdbTable> tables) Publishes the specified tables to all processes that are managed by this class.
void	shutdown() Simple wrapper for disconnect(KdbProcess) to disconnect all processes in the current manager.

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.slf4j.Logger log

publishers

private final ConcurrentHashMap<KdbProcess,KdbPublisherThread> publishers

Map of publishers that are available

Constructor Detail

KdbPublisherManager

public KdbPublisherManager()

Method Detail

addPublisher

public void addPublisher(KdbProcess server)
                  throws KdbTargetProcessUnavailableException,
                         KdbPublisherAlreadyExistsException

Throws:

KdbTargetProcessUnavailableException

KdbPublisherAlreadyExistsException

publish

public void publish(List<KdbTable> tables)

Publishes the specified tables to all processes that are managed by this class.

publish

public void publish(List<KdbProcess> servers,
                    List<KdbTable> tables)
             throws KdbPublisherDoesNotExistException

Provides the ability to publish a number of KdbTable's to a specified list of kdb processes. These processes must already have been added to this manager before attempting to publish.

Parameters:

servers - The known kdb processes to publish the data to

tables - The tables to publish to the kdb processes

Throws:

KdbPublisherDoesNotExistException - If a server is passed that is not known to this manager

getTargetProcesses

public List<KdbProcess> getTargetProcesses()

Returns:

All target kdb processes that are controlled by this publish manager

disconnect

public void disconnect(KdbProcess server)
                throws KdbPublisherDoesNotExistException

Disconnects from the specified kdb server and removes it from the internal management object

Parameters:

server - The kdb process to disconnect from

Throws:

KdbPublisherDoesNotExistException - If the specified kdb process does not exist in this manager

shutdown

public void shutdown()

Simple wrapper for disconnect(KdbProcess) to disconnect all processes in the current manager.