Package deltix.qsrv.hf.tickdb.ui.tbshell

Class TickDBShell

java.lang.Object

deltix.util.cmdline.DefaultApplication

deltix.util.cmdline.AbstractShell

deltix.qsrv.hf.tickdb.ui.tbshell.TickDBShell

public class TickDBShell
extends deltix.util.cmdline.AbstractShell

Timebase command line shell. See help for info.

Field Summary

Fields

Modifier and Type	Field	Description
BenchmarkCommandProcessor	benchmark
DBMgr	dbmgr
L2Processor	l2processor
PlayerCommandProcessor	player
Replicator	replicator
static java.lang.String	SECURITIES_STREAM
Selector	selector

Fields inherited from class deltix.util.cmdline.AbstractShell

STDIN_FILEID

Fields inherited from class deltix.util.cmdline.DefaultApplication

errWriter, outWriter

Constructor Summary

Constructors

Constructor	Description
TickDBShell()

Method Summary

Modifier and Type	Method	Description
static boolean	checkInterrupt()
static void	cleanupEntities(DXTickStream stream)
static RecordClassDescriptor[]	collectTypes(TickStream... streams)
static SchemaConverter	createConverter(DXChannel dest, DXTickStream... src)
TickLoader	createLoader(DXTickStream dest, boolean raw, DXTickStream... excludeStreams)
deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	createPublisher(DXChannel<deltix.qsrv.hf.pub.InstrumentMessage> dest, boolean raw, DXChannel... exclude)
protected boolean	doCommand(java.lang.String key, java.lang.String args, java.lang.String fileId, java.io.LineNumberReader reader)
protected void	doSet()
protected boolean	doSet(java.lang.String option, java.lang.String value)
java.lang.String	expandPath(java.lang.String path)
static java.lang.String	formatDoubleOrOff(double d)
static java.lang.String	formatOnOff(boolean f)
java.lang.String	formatTime(long time)
static java.lang.String	getMultiLineInput(java.lang.String init, java.lang.String fileId, java.io.LineNumberReader reader)
boolean	isTiming()
static void	loadMessageFile(java.io.File srcMsgFile, DXTickStream stream)
static void	main(java.lang.String[] args)
static double	parseDoubleOrOff(java.lang.String value)
static boolean	parseOnOff(java.lang.String s)
long	parseTime(java.lang.String value)
void	setTiming(boolean timing)
void	setTz(java.util.TimeZone tz)
void	startJob(Job job)

Methods inherited from class deltix.util.cmdline.AbstractShell

confirm, doCommand, doExec, doQuit, error, error, getConfirm, getErrorCode, getExitOnError, getKey, getPrompt, run, runCommand, runScript, set, setConfirm, setErrorCode, setExitOnError

Methods inherited from class deltix.util.cmdline.DefaultApplication

createDateFormat, createDecimalFormat, findArg, getArgs, getArgValue, getArgValue, getArgValues, getDateArg, getDateFormatSpec, getDefaultDateFormat, getDefaultTimeZone, getDoubleArgValue, getFileArg, getFileArgs, getIntArgValue, getLongArgValue, getMandatoryArgValue, getMandatoryFileArg, getTimeZone, handleException, isArgSpecified, parseDateTime, printException, printException, printUsage, printUsage, printUsageAndExit, start

Methods inherited from class java.lang.Object

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

Field Detail

SECURITIES_STREAM

public static final java.lang.String SECURITIES_STREAM

See Also:

Constant Field Values

dbmgr

public final DBMgr dbmgr

selector

public final Selector selector

l2processor

public final L2Processor l2processor

replicator

public final Replicator replicator

player

public final PlayerCommandProcessor player

benchmark

public final BenchmarkCommandProcessor benchmark

Constructor Detail

TickDBShell

public TickDBShell()

Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Throwable

Throws:

java.lang.Throwable

parseTime

public long parseTime(java.lang.String value)
               throws java.text.ParseException

Throws:

java.text.ParseException

formatTime

public java.lang.String formatTime(long time)

startJob

public void startJob(Job job)

expandPath

public java.lang.String expandPath(java.lang.String path)

Overrides:

expandPath in class deltix.util.cmdline.AbstractShell

doSet

protected boolean doSet(java.lang.String option,
                        java.lang.String value)
                 throws java.lang.Exception

Overrides:

doSet in class deltix.util.cmdline.AbstractShell

Throws:

java.lang.Exception

formatOnOff

public static java.lang.String formatOnOff(boolean f)

parseOnOff

public static boolean parseOnOff(java.lang.String s)

doSet

protected void doSet()

Overrides:

doSet in class deltix.util.cmdline.AbstractShell

doCommand

protected boolean doCommand(java.lang.String key,
                            java.lang.String args,
                            java.lang.String fileId,
                            java.io.LineNumberReader reader)
                     throws java.lang.Exception

Overrides:

doCommand in class deltix.util.cmdline.AbstractShell

Throws:

java.lang.Exception

createConverter

public static SchemaConverter createConverter(DXChannel dest,
                                              DXTickStream... src)

createLoader

public TickLoader createLoader(DXTickStream dest,
                               boolean raw,
                               DXTickStream... excludeStreams)

createPublisher

public deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> createPublisher(DXChannel<deltix.qsrv.hf.pub.InstrumentMessage> dest,
                                                                                               boolean raw,
                                                                                               DXChannel... exclude)

loadMessageFile

public static void loadMessageFile(java.io.File srcMsgFile,
                                   DXTickStream stream)
                            throws java.io.IOException

Throws:

java.io.IOException

checkInterrupt

public static boolean checkInterrupt()
                              throws java.io.IOException

Throws:

java.io.IOException

collectTypes

public static RecordClassDescriptor[] collectTypes(TickStream... streams)

isTiming

public boolean isTiming()

setTiming

public void setTiming(boolean timing)

setTz

public void setTz(java.util.TimeZone tz)

parseDoubleOrOff

public static double parseDoubleOrOff(java.lang.String value)

formatDoubleOrOff

public static java.lang.String formatDoubleOrOff(double d)

getMultiLineInput

public static java.lang.String getMultiLineInput(java.lang.String init,
                                                 java.lang.String fileId,
                                                 java.io.LineNumberReader reader)
                                          throws java.io.IOException,
                                                 java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

cleanupEntities

public static void cleanupEntities(DXTickStream stream)