Package 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
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.yamcs.cmdhistory.CommandHistoryPublisher
CommandHistoryPublisher.AckStatus
-
-
Field Summary
Fields Modifier and Type Field Description static StringDUMP_CMDHIST_STREAM_NAMEstatic StringREALTIME_CMDHIST_STREAM_NAME-
Fields inherited from interface org.yamcs.cmdhistory.CommandHistoryPublisher
AcknowledgeQueued_KEY, AcknowledgeReleased_KEY, AcknowledgeSent, CcsdsSeq_KEY, CommandComplete_KEY, Queue_KEY, SUFFIX_MESSAGE, SUFFIX_STATUS, SUFFIX_TIME, TransmissionContraints_KEY, Verifier_KEY_PREFIX
-
-
Constructor Summary
Constructors Constructor Description StreamCommandHistoryPublisher(String archiveInstance)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddCommand(PreparedCommand pc)StringgetInstance()StreamgetStream()voidpublish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, byte[] binary)voidpublish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, int value)voidpublish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, long instant)voidpublish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, String value)voidpublish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, DataType dt, Object value)voidpublishAck(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, long time, CommandHistoryPublisher.AckStatus state, String message)Publish an acknowledgement status to the command history.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.yamcs.cmdhistory.CommandHistoryPublisher
commandFailed, publishAck
-
-
-
-
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(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, String value)- Specified by:
publishin interfaceCommandHistoryPublisher
-
publish
public void publish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, long instant)- Specified by:
publishin interfaceCommandHistoryPublisher
-
publish
public void publish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, int value)- Specified by:
publishin interfaceCommandHistoryPublisher
-
publish
public void publish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, byte[] binary)- Specified by:
publishin interfaceCommandHistoryPublisher
-
publish
public void publish(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, DataType dt, Object value)
-
publishAck
public void publishAck(org.yamcs.protobuf.Commanding.CommandId cmdId, String key, long time, CommandHistoryPublisher.AckStatus state, String message)Description copied from interface:CommandHistoryPublisherPublish an acknowledgement status to the command history.Three entries (corresponding to command history columns) are created:
- key_Time
- key_Status
- key_Message
- Specified by:
publishAckin interfaceCommandHistoryPublisher
-
addCommand
public void addCommand(PreparedCommand pc)
- Specified by:
addCommandin interfaceCommandHistoryPublisher
-
getInstance
public String getInstance()
-
getStream
public Stream getStream()
-
-