public class ParameterRequestManager extends com.google.common.util.concurrent.AbstractService implements ParameterListener
| Constructor and Description |
|---|
ParameterRequestManager(Processor yproc,
XtceTmProcessor tmProcessor)
Creates a new ParameterRequestManager, configured to listen to the
specified XtceTmProcessor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addItemsToRequest(int subscriptionId,
List<Parameter> paraList)
Add items to a subscription.
|
void |
addItemsToRequest(int subscriptionId,
Parameter para)
Add items to an request id.
|
void |
addParameterProvider(ParameterProvider parameterProvider) |
void |
addRequest(int subscriptionId,
List<Parameter> paraList,
ParameterConsumer tpc)
Create request with a given id.
|
int |
addRequest(List<Parameter> paraList,
DVParameterConsumer dvtpc)
Creates a new request with a list of parameters
|
int |
addRequest(List<Parameter> paraList,
ParameterConsumer tpc) |
int |
addRequest(Parameter para,
ParameterConsumer tpc)
Creates a request with one parameter
|
protected void |
doStart() |
protected void |
doStop() |
AlarmChecker |
getAlarmChecker() |
AlarmServer |
getAlarmServer() |
ParameterValue |
getLastValueFromCache(Parameter param)
Get the last value from cache for a specific parameters
|
Parameter |
getParameter(String fqn)
returns a parameter based on fully qualified name
|
Parameter |
getParameter(Yamcs.NamedObjectId paraId) |
ParameterCache |
getParameterCache() |
<T extends ParameterProvider> |
getParameterProvider(Class<T> type) |
SoftwareParameterManager |
getSoftwareParameterManager() |
List<ParameterValue> |
getValuesFromCache(List<Parameter> plist) |
List<ParameterValue> |
getValuesFromCache(Parameter param)
Get all the values from cache for a specific parameters
The parameter are returned in descending order (newest parameter is returned first)
|
Object |
getXtceDb() |
boolean |
hasParameterCache() |
void |
init()
This is called after all the parameter providers have been added but before the start.
|
void |
removeItemsFromRequest(int subscriptionID,
List<Parameter> paraList)
Removes a list of parameters from a request.
|
void |
removeItemsFromRequest(int subscriptionID,
Parameter param)
Removes a parameter from a rquest.
|
List<Parameter> |
removeRequest(int subscriptionId)
Removes all the items from this subscription and returns them into an
List.
|
int |
subscribeAll(ParameterConsumer consumer)
subscribes to all parameters
|
String |
toString() |
boolean |
unsubscribeAll(int subscriptionId)
removes the subscription to all parameters
return true of the subscription has been removed or false if it was not there
|
void |
update(Collection<ParameterValue> params)
Called each time some parameters have been updated.
|
public final Processor yproc
public ParameterRequestManager(Processor yproc, XtceTmProcessor tmProcessor) throws ConfigurationException
ConfigurationExceptionpublic void addParameterProvider(ParameterProvider parameterProvider)
public void init()
public int subscribeAll(ParameterConsumer consumer)
public boolean unsubscribeAll(int subscriptionId)
subscriptionId - public int addRequest(List<Parameter> paraList, ParameterConsumer tpc)
public int addRequest(Parameter para, ParameterConsumer tpc)
para - tpc - public int addRequest(List<Parameter> paraList, DVParameterConsumer dvtpc)
paraList - dvtpc - public void addRequest(int subscriptionId,
List<Parameter> paraList,
ParameterConsumer tpc)
subscriptionId - - subscription idparaList - tpc - public void addItemsToRequest(int subscriptionId,
Parameter para)
throws InvalidRequestIdentification
subscriptionId - para - InvalidRequestIdentificationpublic void addItemsToRequest(int subscriptionId,
List<Parameter> paraList)
throws InvalidRequestIdentification
subscriptionId - paraList - - list of parameters that are added to the subscriptionInvalidIdentificationInvalidRequestIdentificationpublic void removeItemsFromRequest(int subscriptionID,
Parameter param)
subscriptionID - param - InvalidIdentificationpublic void removeItemsFromRequest(int subscriptionID,
List<Parameter> paraList)
subscriptionID - paraList - public List<Parameter> removeRequest(int subscriptionId)
public Parameter getParameter(String fqn) throws InvalidIdentification
fqn - InvalidIdentificationpublic Parameter getParameter(Yamcs.NamedObjectId paraId) throws InvalidIdentification
paraId - InvalidIdentification - in case no provider knows of this parameter.public void update(Collection<ParameterValue> params)
ParameterListenerupdate in interface ParameterListenerparams - - new delivered parameter valuespublic SoftwareParameterManager getSoftwareParameterManager()
public <T extends ParameterProvider> T getParameterProvider(Class<T> type)
public AlarmChecker getAlarmChecker()
public String toString()
toString in class com.google.common.util.concurrent.AbstractServicepublic AlarmServer getAlarmServer()
public boolean hasParameterCache()
public List<ParameterValue> getValuesFromCache(List<Parameter> plist)
public ParameterValue getLastValueFromCache(Parameter param)
param - public List<ParameterValue> getValuesFromCache(Parameter param)
param - public ParameterCache getParameterCache()
public Object getXtceDb()
protected void doStart()
doStart in class com.google.common.util.concurrent.AbstractServiceprotected void doStop()
doStop in class com.google.common.util.concurrent.AbstractServiceCopyright © 2018 Space Applications Services. All rights reserved.