Package org.yamcs.management

Class ManagementService

java.lang.Object

org.yamcs.management.ManagementService

All Implemented Interfaces:

ProcessorListener

public class ManagementService
extends Object
implements ProcessorListener

Responsible for providing to interested listeners info related to creation/removal/update of:

• instances, processors and clients - see ManagementListener
• streams and tables - see TableStreamListener
• command queues - see CommandQueueListener

Method Summary

Modifier and Type	Method	Description
boolean	addCommandQueueListener(CommandQueueListener l)
boolean	addManagementListener(ManagementListener l)	Adds a listener that is to be notified when any processor, or any client is updated.
boolean	addTableStreamListener(TableStreamListener l)
void	connectToProcessor(Processor processor, int clientId)
void	connectToProcessor(org.yamcs.protobuf.ProcessorManagementRequest cr)
void	createProcessor(org.yamcs.protobuf.ProcessorManagementRequest pmr, String username)
ConnectedClient	getClient(int clientId)
Set<ConnectedClient>	getClients()
Set<ConnectedClient>	getClients(String username)
CommandQueueManager	getCommandQueueManager(Processor processor)
List<CommandQueueManager>	getCommandQueueManagers()
static ManagementService	getInstance()
CommandQueueManager	getQueueManager(String instance, String processorName)
List<CommandQueueManager>	getQueueManagers()
void	processorAdded(Processor processor)
void	processorClosed(Processor processor)
void	processorStateChanged(Processor processor)
void	registerClient(ConnectedClient client)
void	registerCommandQueueManager(String instance, String processorName, CommandQueueManager cqm)
void	registerService(String instance, String serviceName, com.google.common.util.concurrent.Service service)
void	registerStream(String instance, Stream stream)
void	registerTable(String instance, TableDefinition tblDef)
void	registerYamcsInstance(YamcsServerInstance ys)
boolean	removeCommandQueueListener(CommandQueueListener l)
boolean	removeManagementListener(ManagementListener l)
boolean	removeTableStreamListener(TableStreamListener l)
void	shutdown()
void	unregisterClient(int id)
void	unregisterCommandQueueManager(String instance, String processorName, CommandQueueManager cqm)
void	unregisterService(String instance, String serviceName)
void	unregisterStream(String instance, String name)
void	unregisterTable(String instance, String tblName)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static ManagementService getInstance()

shutdown

public void shutdown()

registerService

public void registerService(String instance,
                            String serviceName,
                            com.google.common.util.concurrent.Service service)

unregisterService

public void unregisterService(String instance,
                              String serviceName)

getQueueManager

public CommandQueueManager getQueueManager(String instance,
                                           String processorName)
                                    throws YamcsException

Throws:

YamcsException

getQueueManagers

public List<CommandQueueManager> getQueueManagers()

registerClient

public void registerClient(ConnectedClient client)

unregisterClient

public void unregisterClient(int id)

createProcessor

public void createProcessor(org.yamcs.protobuf.ProcessorManagementRequest pmr,
                            String username)
                     throws YamcsException

Throws:

YamcsException

connectToProcessor

public void connectToProcessor(Processor processor,
                               int clientId)
                        throws YamcsException,
                               ProcessorException

Throws:

YamcsException

ProcessorException

connectToProcessor

public void connectToProcessor(org.yamcs.protobuf.ProcessorManagementRequest cr)
                        throws YamcsException

Throws:

YamcsException

registerCommandQueueManager

public void registerCommandQueueManager(String instance,
                                        String processorName,
                                        CommandQueueManager cqm)

unregisterCommandQueueManager

public void unregisterCommandQueueManager(String instance,
                                          String processorName,
                                          CommandQueueManager cqm)

getCommandQueueManagers

public List<CommandQueueManager> getCommandQueueManagers()

getCommandQueueManager

public CommandQueueManager getCommandQueueManager(Processor processor)

addManagementListener

public boolean addManagementListener(ManagementListener l)

Adds a listener that is to be notified when any processor, or any client is updated. Calling this multiple times has no extra effects. Either you listen, or you don't.

removeManagementListener

public boolean removeManagementListener(ManagementListener l)

addCommandQueueListener

public boolean addCommandQueueListener(CommandQueueListener l)

addTableStreamListener

public boolean addTableStreamListener(TableStreamListener l)

removeTableStreamListener

public boolean removeTableStreamListener(TableStreamListener l)

removeCommandQueueListener

public boolean removeCommandQueueListener(CommandQueueListener l)

getClients

public Set<ConnectedClient> getClients()

getClients

public Set<ConnectedClient> getClients(String username)

getClient

public ConnectedClient getClient(int clientId)

processorAdded

public void processorAdded(Processor processor)

Specified by:

processorAdded in interface ProcessorListener

processorClosed

public void processorClosed(Processor processor)

Specified by:

processorClosed in interface ProcessorListener

processorStateChanged

public void processorStateChanged(Processor processor)

Specified by:

processorStateChanged in interface ProcessorListener

registerYamcsInstance

public void registerYamcsInstance(YamcsServerInstance ys)

registerTable

public void registerTable(String instance,
                          TableDefinition tblDef)

registerStream

public void registerStream(String instance,
                           Stream stream)

unregisterTable

public void unregisterTable(String instance,
                            String tblName)

unregisterStream

public void unregisterStream(String instance,
                             String name)