org.yamcs.parameter

Class ParameterWithIdRequestHelper

java.lang.Object

org.yamcs.parameter.ParameterWithIdRequestHelper

All Implemented Interfaces:

ParameterConsumer

public class ParameterWithIdRequestHelper
extends Object
implements ParameterConsumer

This sits in front of the ParameterRequestManager and implements subscriptions based on NamedObjectId taking care to send to the consumers the parameters with the requested id. A client can request in fact the same parameter with two different names and they will get it twice each time TODO: check privileges and subscription limits

Author:

nm

Constructor Summary

Constructors

Constructor and Description
ParameterWithIdRequestHelper(ParameterRequestManagerImpl prm, ParameterWithIdConsumer listener)

Method Summary

Modifier and Type	Method and Description
void	addItemsToRequest(int subscriptionId, List<Yamcs.NamedObjectId> idList, AuthenticationToken authToken)
int	addRequest(List<Yamcs.NamedObjectId> idList, AuthenticationToken authToken)
ParameterRequestManagerImpl	getPrm()
List<ParameterValueWithId>	getValuesFromCache(List<Yamcs.NamedObjectId> idList, AuthenticationToken authToken)
boolean	hasParameterCache()
void	removeItemsFromRequest(int subscriptionId, List<Yamcs.NamedObjectId> parameterIds, AuthenticationToken authToken)
void	removeRequest(int subscriptionId)
int	subscribeAll(String namespace, AuthenticationToken authToken)
void	switchPrm(ParameterRequestManagerImpl newPrm, AuthenticationToken authToken)
void	updateItems(int subscriptionId, List<ParameterValue> items)

Methods inherited from class java.lang.Object

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

Constructor Detail

ParameterWithIdRequestHelper

public ParameterWithIdRequestHelper(ParameterRequestManagerImpl prm,
                                    ParameterWithIdConsumer listener)

Method Detail

addRequest

public int addRequest(List<Yamcs.NamedObjectId> idList,
                      AuthenticationToken authToken)
               throws InvalidIdentification,
                      NoPermissionException

Throws:

InvalidIdentification

NoPermissionException

addItemsToRequest

public void addItemsToRequest(int subscriptionId,
                              List<Yamcs.NamedObjectId> idList,
                              AuthenticationToken authToken)
                       throws InvalidIdentification,
                              NoPermissionException

Throws:

InvalidIdentification

NoPermissionException

removeRequest

public void removeRequest(int subscriptionId)

removeItemsFromRequest

public void removeItemsFromRequest(int subscriptionId,
                                   List<Yamcs.NamedObjectId> parameterIds,
                                   AuthenticationToken authToken)
                            throws NoPermissionException

Throws:

NoPermissionException

getPrm

public ParameterRequestManagerImpl getPrm()

subscribeAll

public int subscribeAll(String namespace,
                        AuthenticationToken authToken)
                 throws NoPermissionException

Throws:

NoPermissionException

updateItems

public void updateItems(int subscriptionId,
                        List<ParameterValue> items)

Specified by:

updateItems in interface ParameterConsumer

getValuesFromCache

public List<ParameterValueWithId> getValuesFromCache(List<Yamcs.NamedObjectId> idList,
                                                     AuthenticationToken authToken)
                                              throws InvalidIdentification,
                                                     NoPermissionException

Throws:

InvalidIdentification

NoPermissionException

switchPrm

public void switchPrm(ParameterRequestManagerImpl newPrm,
                      AuthenticationToken authToken)
               throws InvalidIdentification,
                      NoPermissionException

Throws:

InvalidIdentification

NoPermissionException

hasParameterCache

public boolean hasParameterCache()