Package deltix.qsrv.hf.tickdb

Class TDBRunner

java.lang.Object

deltix.qsrv.hf.tickdb.TDBRunner

public class TDBRunner
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TDBRunner.BarsGenerator
static class	TDBRunner.BaseGenerator<T>
static class	TDBRunner.BBOGenerator
static class	TDBRunner.CycleIterator<T>
static class	TDBRunner.TradesGenerator

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	embeddedTopics
DataCacheOptions	options
java.lang.String	pass
protected boolean	remote
TransportProperties	transportProperties
java.lang.String	user
boolean	useSSL

Constructor Summary

Constructors

Constructor	Description
TDBRunner(boolean isRemote)
TDBRunner(boolean isRemote, boolean doFormat)
TDBRunner(boolean isRemote, boolean doFormat, EmbeddedServer server)
TDBRunner(boolean isRemote, boolean doFormat, java.lang.String location)
TDBRunner(boolean isRemote, boolean doFormat, java.lang.String location, EmbeddedServer server)
TDBRunner(boolean isRemote, boolean doFormat, java.lang.String location, EmbeddedServer server, boolean enableLocalTopics)

Method Summary

Modifier and Type	Method	Description
protected void	close()
DXTickDB	createClient()
DXTickStream	createStream(DXTickDB db, java.lang.String key, StreamOptions so)
java.lang.String	getLocation()
int	getPort()
DXTickDB	getServerDb()
static java.lang.String	getTemporaryLocation()
static java.lang.String	getTemporaryLocation(java.lang.String subpath)
DXTickDB	getTickDb()
protected void	open(boolean ro)
void	setCleanup(boolean cleanup)	Enables cleanup on shutdown (all local data gets deleted).
void	setDoFormat(boolean doFormat)
void	setPort(int port)
void	shutdown()
void	startup()

Methods inherited from class java.lang.Object

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

Field Detail

remote

protected final boolean remote

embeddedTopics

protected final boolean embeddedTopics

options

public DataCacheOptions options

user

public java.lang.String user

pass

public java.lang.String pass

transportProperties

public TransportProperties transportProperties

useSSL

public boolean useSSL

Constructor Detail

TDBRunner

public TDBRunner(boolean isRemote)

TDBRunner

public TDBRunner(boolean isRemote,
                 boolean doFormat)

TDBRunner

public TDBRunner(boolean isRemote,
                 boolean doFormat,
                 java.lang.String location)

TDBRunner

public TDBRunner(boolean isRemote,
                 boolean doFormat,
                 EmbeddedServer server)

TDBRunner

public TDBRunner(boolean isRemote,
                 boolean doFormat,
                 java.lang.String location,
                 EmbeddedServer server)

TDBRunner

public TDBRunner(boolean isRemote,
                 boolean doFormat,
                 java.lang.String location,
                 EmbeddedServer server,
                 boolean enableLocalTopics)

Method Detail

getTemporaryLocation

public static java.lang.String getTemporaryLocation()

getTemporaryLocation

public static java.lang.String getTemporaryLocation(java.lang.String subpath)

startup

public void startup()
             throws java.lang.Exception

Throws:

java.lang.Exception

createClient

public DXTickDB createClient()

shutdown

public void shutdown()
              throws java.lang.Exception

Throws:

java.lang.Exception

getTickDb

public DXTickDB getTickDb()

getServerDb

public DXTickDB getServerDb()

open

protected void open(boolean ro)

close

protected void close()

setDoFormat

public void setDoFormat(boolean doFormat)

setPort

public void setPort(int port)

getPort

public int getPort()

createStream

public DXTickStream createStream(DXTickDB db,
                                 java.lang.String key,
                                 StreamOptions so)

getLocation

public java.lang.String getLocation()

setCleanup

public void setCleanup(boolean cleanup)

Enables cleanup on shutdown (all local data gets deleted).