org.yamcs.archive

Class XtceTmRecorder

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.archive.XtceTmRecorder

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class XtceTmRecorder
extends com.google.common.util.concurrent.AbstractService

Records XTCE TM sequence containers. It creates a stream for each sequence container under the root. TODO: make it more configurable

Author:

nm

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
static String	DUMP_TM_STREAM_NAME
protected org.slf4j.Logger	log
static String	PNAME_COLUMN
static String	REALTIME_TM_STREAM_NAME
static TupleDefinition	RECORDED_TM_TUPLE_DEFINITION
static String	TABLE_NAME

Constructor Summary

Constructors

Constructor and Description
XtceTmRecorder(String yamcsInstance)
XtceTmRecorder(String yamcsInstance, Map<String,Object> config) old constructor for compatibility with older configuration files

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
long	getNumProcessedPackets()

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.slf4j.Logger log

REALTIME_TM_STREAM_NAME

public static String REALTIME_TM_STREAM_NAME

DUMP_TM_STREAM_NAME

public static String DUMP_TM_STREAM_NAME

TABLE_NAME

public static final String TABLE_NAME

See Also:

Constant Field Values

PNAME_COLUMN

public static final String PNAME_COLUMN

See Also:

Constant Field Values

RECORDED_TM_TUPLE_DEFINITION

public static final TupleDefinition RECORDED_TM_TUPLE_DEFINITION

Constructor Detail

XtceTmRecorder

public XtceTmRecorder(String yamcsInstance)
               throws IOException,
                      ConfigurationException,
                      StreamSqlException,
                      ParseException,
                      YamcsApiException

Throws:

IOException

ConfigurationException

StreamSqlException

ParseException

YamcsApiException

XtceTmRecorder

public XtceTmRecorder(String yamcsInstance,
                      Map<String,Object> config)
               throws IOException,
                      ConfigurationException,
                      StreamSqlException,
                      ParseException,
                      YamcsApiException

old constructor for compatibility with older configuration files

Parameters:

yamcsInstance -

Throws:

IOException

ConfigurationException

StreamSqlException

ParseException

YamcsApiException

Method Detail

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService

getNumProcessedPackets

public long getNumProcessedPackets()