Package org.yamcs.ygw

Class YgwCommandManager

java.lang.Object

org.yamcs.ygw.YgwCommandManager

All Implemented Interfaces:

StreamSubscriber

public class YgwCommandManager
extends Object
implements StreamSubscriber

Handles direct commands registered by YGW nodes by sending Ygw.CommandDefinitionList

Creates a stream and registers it in the processor using StreamTcCommandReleaser.registerOutStream(int, Stream, org.yamcs.StreamTcCommandReleaser.CommandMatcher)

The stream is given top priority and it verifies the command against all command registered from the YGW nodes and recorded in commands

Constructor Summary

Constructors

Constructor	Description
YgwCommandManager(YgwLink parentLink, Processor processor, String yamcsInstance)

Method Summary

Modifier and Type	Method	Description
void	addCommandDefs(String namespace, org.yamcs.ygw.protobuf.Ygw.CommandDefinitionList cdefs, YgwNodeLink nodeLink)
void	onTuple(Stream stream, Tuple tuple)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.yarch.StreamSubscriber

streamClosed

Constructor Details

YgwCommandManager

public YgwCommandManager(YgwLink parentLink,
 Processor processor,
 String yamcsInstance)

Method Details

addCommandDefs

public void addCommandDefs(String namespace,
 org.yamcs.ygw.protobuf.Ygw.CommandDefinitionList cdefs,
 YgwNodeLink nodeLink)

onTuple

public void onTuple(Stream stream,
 Tuple tuple)

Specified by:

onTuple in interface StreamSubscriber