org.yamcs.container

Class ContainerRequestManager

java.lang.Object

org.yamcs.container.ContainerRequestManager

All Implemented Interfaces:

ContainerListener

public class ContainerRequestManager
extends Object
implements ContainerListener

Keeps track of the subscribers to the containers of a Yamcs Channel.

Constructor Summary

Constructors

Constructor and Description
ContainerRequestManager(Processor proc) Creates a new ContainerRequestManager, configured to listen to a newly created XtceTmProcessor.
ContainerRequestManager(Processor proc, XtceTmProcessor tmProcessor) Creates a new ContainerRequestManager, configured to listen to the specified XtceTmProcessor.

Method Summary

Modifier and Type	Method and Description
XtceTmProcessor	getTmProcessor()
XtceDb	getXtceDb()
void	subscribe(ContainerConsumer subscriber, SequenceContainer container)
void	subscribeAll(ContainerConsumer subscriber)
void	unsubscribe(ContainerConsumer subscriber, SequenceContainer container)
void	unsubscribeAll(ContainerConsumer subscriber)
void	update(List<ContainerExtractionResult> results)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContainerRequestManager

public ContainerRequestManager(Processor proc)

Creates a new ContainerRequestManager, configured to listen to a newly created XtceTmProcessor.

ContainerRequestManager

public ContainerRequestManager(Processor proc,
                               XtceTmProcessor tmProcessor)

Creates a new ContainerRequestManager, configured to listen to the specified XtceTmProcessor.

Method Detail

subscribe

public void subscribe(ContainerConsumer subscriber,
                      SequenceContainer container)

subscribeAll

public void subscribeAll(ContainerConsumer subscriber)

unsubscribe

public void unsubscribe(ContainerConsumer subscriber,
                        SequenceContainer container)

unsubscribeAll

public void unsubscribeAll(ContainerConsumer subscriber)

update

public void update(List<ContainerExtractionResult> results)

Specified by:

update in interface ContainerListener

getTmProcessor

public XtceTmProcessor getTmProcessor()

getXtceDb

public XtceDb getXtceDb()