org.yamcs.cmdhistory

Class YarchCommandHistoryAdapter

java.lang.Object

org.yamcs.cmdhistory.YarchCommandHistoryAdapter

All Implemented Interfaces:

CommandHistoryPublisher

public class YarchCommandHistoryAdapter
extends Object
implements CommandHistoryPublisher

Injects the command history updates in the command history stream

Author:

nm

Field Summary

Fields

Modifier and Type	Field and Description
static String	DUMP_CMDHIST_STREAM_NAME
static String	REALTIME_CMDHIST_STREAM_NAME

Fields inherited from interface org.yamcs.cmdhistory.CommandHistoryPublisher

CommandComplete_KEY, CommandFailed_KEY, TransmissionContraints_KEY, Verifier_KEY_PREFIX

Constructor Summary

Constructors

Constructor and Description
YarchCommandHistoryAdapter(String archiveInstance)

Method Summary

Modifier and Type	Method and Description
void	addCommand(PreparedCommand pc)
String	getInstance()
Stream	getStream()
void	publish(Commanding.CommandId cmdId, String key, DataType dt, Object value)
void	publish(Commanding.CommandId cmdId, String key, int value)
void	updateStringKey(Commanding.CommandId cmdId, String key, String value)
void	updateTimeKey(Commanding.CommandId cmdId, String key, long instant)

Methods inherited from class java.lang.Object

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

Field Detail

REALTIME_CMDHIST_STREAM_NAME

public static final String REALTIME_CMDHIST_STREAM_NAME

See Also:

Constant Field Values

DUMP_CMDHIST_STREAM_NAME

public static final String DUMP_CMDHIST_STREAM_NAME

See Also:

Constant Field Values

Constructor Detail

YarchCommandHistoryAdapter

public YarchCommandHistoryAdapter(String archiveInstance)
                           throws StreamSqlException,
                                  ParseException

Throws:

StreamSqlException

ParseException

Method Detail

updateStringKey

public void updateStringKey(Commanding.CommandId cmdId,
                            String key,
                            String value)

Specified by:

updateStringKey in interface CommandHistoryPublisher

updateTimeKey

public void updateTimeKey(Commanding.CommandId cmdId,
                          String key,
                          long instant)

Specified by:

updateTimeKey in interface CommandHistoryPublisher

publish

public void publish(Commanding.CommandId cmdId,
                    String key,
                    int value)

Specified by:

publish in interface CommandHistoryPublisher

publish

public void publish(Commanding.CommandId cmdId,
                    String key,
                    DataType dt,
                    Object value)

addCommand

public void addCommand(PreparedCommand pc)

Specified by:

addCommand in interface CommandHistoryPublisher

getInstance

public String getInstance()

getStream

public Stream getStream()