Uses of Class
com.buabook.kdb.connection.KdbProcess

Packages that use KdbProcess

Package	Description
com.buabook.kdb.connection
com.buabook.kdb.consumer
com.buabook.kdb.publisher
com.buabook.kdb.query

Uses of KdbProcess in com.buabook.kdb.connection

Fields in com.buabook.kdb.connection declared as KdbProcess

Modifier and Type	Field and Description
private KdbProcess	KdbConnection.process The details of the process to connect to

Methods in com.buabook.kdb.connection that return KdbProcess

Modifier and Type	Method and Description
KdbProcess	KdbConnection.getRemoteProcess()

Constructors in com.buabook.kdb.connection with parameters of type KdbProcess

Constructor and Description
KdbConnection(KdbProcess process) Creates a new kdb connection object with the reconnection interval set as the default (as defined by KdbConnection.DEFAULT_RECONNECT_INTERVAL_MS.
KdbConnection(KdbProcess process, Integer reconnectIntervalMs) Creates a new kdb connection object with the specified reconnection interval.

Uses of KdbProcess in com.buabook.kdb.consumer

Constructors in com.buabook.kdb.consumer with parameters of type KdbProcess

Constructor and Description
KdbConsumer(KdbProcess server, KdbDict subscriptionConfiguration, IKdbRawDataConsumer rawDataConsumer, IKdbTableConsumer tableConsumer)
KdbConsumer(KdbProcess server, List<String> tables, IKdbRawDataConsumer rawDataConsumer, IKdbTableConsumer tableConsumer) Generates a new kdb consumer (which is generally a consumer from a kdb TickerPlant)
KdbConsumer(KdbProcess server, List<String> tables, IKdbTableConsumer tableConsumer)
KdbConsumer(KdbProcess server, List<String> tables, KdbDict subscriptionConfiguration, IKdbRawDataConsumer rawDataConsumer, IKdbTableConsumer tableConsumer)
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.

Uses of KdbProcess in com.buabook.kdb.publisher

Fields in com.buabook.kdb.publisher with type parameters of type KdbProcess

Modifier and Type	Field and Description
private ConcurrentHashMap<KdbProcess,KdbPublisherThread>	KdbPublisherManager.publishers Map of publishers that are available

Methods in com.buabook.kdb.publisher that return types with arguments of type KdbProcess

Modifier and Type	Method and Description
List<KdbProcess>	KdbPublisherManager.getTargetProcesses()

Methods in com.buabook.kdb.publisher with parameters of type KdbProcess

Modifier and Type	Method and Description
void	KdbPublisherManager.addPublisher(KdbProcess server)
void	KdbPublisherManager.disconnect(KdbProcess server) Disconnects from the specified kdb server and removes it from the internal management object

Method parameters in com.buabook.kdb.publisher with type arguments of type KdbProcess

Modifier and Type	Method and Description
void	KdbPublisherManager.publish(List<KdbProcess> servers, List<KdbTable> tables) Provides the ability to publish a number of KdbTable's to a specified list of kdb processes.

Constructors in com.buabook.kdb.publisher with parameters of type KdbProcess

Constructor and Description
KdbPublisher(KdbProcess server)
KdbPublisher(KdbProcess server, org.joda.time.Duration resetConnectionDuration) Generates a new KDB publisher.
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)

Uses of KdbProcess in com.buabook.kdb.query

Constructors in com.buabook.kdb.query with parameters of type KdbProcess

Constructor and Description
KdbAsyncQuery(KdbProcess target)
KdbQuery(KdbProcess target) Constructs a new query object, first opening an connection to the specified process
KdbSyncQuery(KdbProcess target)