org.yamcs.cmdhistory

Class StreamCommandHistoryPublisher

java.lang.Object

org.yamcs.cmdhistory.StreamCommandHistoryPublisher

All Implemented Interfaces:

CommandHistoryPublisher

public class StreamCommandHistoryPublisher
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
StreamCommandHistoryPublisher(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	publish(Commanding.CommandId cmdId, String key, long instant)
void	publish(Commanding.CommandId cmdId, String key, String value)
void	publishWithTime(Commanding.CommandId cmdId, String key, long time, String value)

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

StreamCommandHistoryPublisher

public StreamCommandHistoryPublisher(String archiveInstance)

Method Detail

publish

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

Specified by:

publish in interface CommandHistoryPublisher

publish

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

Specified by:

publish 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)

publishWithTime

public void publishWithTime(Commanding.CommandId cmdId,
                            String key,
                            long time,
                            String value)

Specified by:

publishWithTime in interface CommandHistoryPublisher

addCommand

public void addCommand(PreparedCommand pc)

Specified by:

addCommand in interface CommandHistoryPublisher

getInstance

public String getInstance()

getStream

public Stream getStream()