public class RuntimeManager
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<java.lang.Integer,CompoundEventDetectorRT> |
compoundEventDetectors
Store of enabled compound event detectors.
|
private java.util.Map<java.lang.Integer,DataPointListener> |
dataPointListeners
The list of point listeners, kept here such that listeners can be
notified of point initializations (i.e. a listener can register itself
before the point is enabled).
|
private java.util.Map<java.lang.Integer,DataPointRT> |
dataPoints
Provides a quick lookup map of the running data points.
|
private static org.apache.commons.logging.Log |
LOG |
private java.util.List<MaintenanceEventRT> |
maintenanceEvents
Store of maintenance events
|
private java.util.List<PointLinkRT> |
pointLinks
Store of enabled point links
|
private java.util.List<DataSourceRT> |
runningDataSources |
private java.util.List<PublisherRT<?>> |
runningPublishers
Store of enabled publishers
|
private java.util.Map<java.lang.String,SimpleEventDetector> |
simpleEventDetectors
Store of enabled event detectors.
|
private boolean |
started |
private UserCache |
userCache
Store of User Permissions
|
| Constructor and Description |
|---|
RuntimeManager() |
private static final org.apache.commons.logging.Log LOG
private final java.util.List<DataSourceRT> runningDataSources
private final java.util.Map<java.lang.Integer,DataPointRT> dataPoints
private final java.util.Map<java.lang.Integer,DataPointListener> dataPointListeners
private final java.util.Map<java.lang.String,SimpleEventDetector> simpleEventDetectors
private final java.util.Map<java.lang.Integer,CompoundEventDetectorRT> compoundEventDetectors
private final java.util.List<PublisherRT<?>> runningPublishers
private final java.util.List<PointLinkRT> pointLinks
private final java.util.List<MaintenanceEventRT> maintenanceEvents
private final UserCache userCache
private boolean started
public void initialize(boolean safe)
public void terminate()
public void joinTermination()
public DataSourceRT getRunningDataSource(int dataSourceId)
public boolean isDataSourceRunning(int dataSourceId)
public java.util.List<DataSourceVO<?>> getDataSources()
public DataSourceVO<?> getDataSource(int dataSourceId)
public void deleteDataSource(int dataSourceId)
public void saveDataSource(DataSourceVO<?> vo)
private boolean initializeDataSource(DataSourceVO<?> vo)
private void startDataSourcePolling(DataSourceVO<?> vo)
public void stopDataSource(int id)
public void saveDataPoint(DataPointVO point)
public void deleteDataPoint(DataPointVO point)
private void startDataPoint(DataPointVO vo)
private void stopDataPoint(int dataPointId)
public boolean isDataPointRunning(int dataPointId)
public DataPointRT getDataPoint(int dataPointId)
public void addDataPointListener(int dataPointId,
DataPointListener l)
public void removeDataPointListener(int dataPointId,
DataPointListener l)
public DataPointListener getDataPointListeners(int dataPointId)
public void setDataPointValue(int dataPointId,
MangoValue value,
SetPointSource source)
public void setDataPointValue(int dataPointId,
PointValueTime valueTime,
SetPointSource source)
public void relinquish(int dataPointId)
public void forcePointRead(int dataPointId)
public long purgeDataPointValues()
public long purgeDataPointValues(int dataPointId,
int periodType,
int periodCount)
public long purgeDataPointValues(int dataPointId)
public long purgeDataPointValues(int dataPointId,
long before)
private void updateDataPointValuesRT(int dataPointId)
public void saveScheduledEvent(ScheduledEventVO vo)
private void startScheduledEvent(ScheduledEventVO vo)
public void stopSimpleEventDetector(java.lang.String key)
public void addPointEventDetector(PointEventDetectorRT ped)
public void removePointEventDetector(java.lang.String pointEventDetectorKey)
public SimpleEventDetector getSimpleEventDetector(java.lang.String key)
public boolean saveCompoundEventDetector(CompoundEventDetectorVO vo)
public boolean startCompoundEventDetector(CompoundEventDetectorVO ced)
public void stopCompoundEventDetector(int compoundEventDetectorId)
public PublisherRT<?> getRunningPublisher(int publisherId)
public boolean isPublisherRunning(int publisherId)
public PublisherVO<? extends PublishedPointVO> getPublisher(int publisherId)
public void deletePublisher(int publisherId)
public void savePublisher(PublisherVO<? extends PublishedPointVO> vo)
private void startPublisher(PublisherVO<? extends PublishedPointVO> vo)
private void stopPublisher(int id)
private PointLinkRT getRunningPointLink(int pointLinkId)
public boolean isPointLinkRunning(int pointLinkId)
public void deletePointLink(int pointLinkId)
public void savePointLink(PointLinkVO vo)
private void startPointLink(PointLinkVO vo)
private void stopPointLink(int id)
public MaintenanceEventRT getRunningMaintenanceEvent(int id)
public boolean isActiveMaintenanceEvent(int dataSourceId)
public boolean isMaintenanceEventRunning(int id)
public void deleteMaintenanceEvent(int id)
public void saveMaintenanceEvent(MaintenanceEventVO vo)
private void startMaintenanceEvent(MaintenanceEventVO vo)
private void stopMaintenanceEvent(int id)