com.serotonin.mango.rt.dataSource.persistent

Class PersistentDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.EventDataSource

com.serotonin.mango.rt.dataSource.persistent.PersistentDataSourceRT

All Implemented Interfaces:

com.serotonin.util.ILifecycle, java.lang.Runnable

public class PersistentDataSourceRT
extends EventDataSource
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	PersistentDataSourceRT.ConnectionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.List<PersistentDataSourceRT.ConnectionHandler>	connectionHandlers
static int	DATA_SOURCE_EXCEPTION_EVENT
(package private) org.apache.commons.logging.Log	log
(package private) java.util.Map<java.lang.String,DataPointRT>	pointXids
(package private) java.net.ServerSocket	serverSocket
(package private) PersistentDataSourceVO	vo

Fields inherited from class com.serotonin.mango.rt.dataSource.EventDataSource

dataPoints

Fields inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints

Constructor Summary

Constructors

Constructor and Description
PersistentDataSourceRT(PersistentDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(DataPointRT dataPoint)
void	beginPolling()
java.lang.String	getConnectionAddress(int index)
int	getConnectionCount()
long	getConnectionTime(int index)
long	getPacketsReceived(int index)
void	initialize()
void	joinTermination()
void	removeDataPoint(DataPointRT dataPoint)
void	run()
void	terminate()

Methods inherited from class com.serotonin.mango.rt.dataSource.EventDataSource

setPointValue

Methods inherited from class com.serotonin.mango.rt.dataSource.DataSourceRT

forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, returnToNormal, setPersistentData

Methods inherited from class java.lang.Object

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

Field Detail

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

log

final org.apache.commons.logging.Log log

vo

final PersistentDataSourceVO vo

serverSocket

volatile java.net.ServerSocket serverSocket

pointXids

final java.util.Map<java.lang.String,DataPointRT> pointXids

connectionHandlers

final java.util.List<PersistentDataSourceRT.ConnectionHandler> connectionHandlers

Constructor Detail

PersistentDataSourceRT

public PersistentDataSourceRT(PersistentDataSourceVO vo)

Method Detail

getConnectionCount

public int getConnectionCount()

getConnectionAddress

public java.lang.String getConnectionAddress(int index)

getConnectionTime

public long getConnectionTime(int index)

getPacketsReceived

public long getPacketsReceived(int index)

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class DataSourceRT

joinTermination

public void joinTermination()

Specified by:

joinTermination in interface com.serotonin.util.ILifecycle

Overrides:

joinTermination in class DataSourceRT

beginPolling

public void beginPolling()

Overrides:

beginPolling in class DataSourceRT

addDataPoint

public void addDataPoint(DataPointRT dataPoint)

Overrides:

addDataPoint in class EventDataSource

removeDataPoint

public void removeDataPoint(DataPointRT dataPoint)

Overrides:

removeDataPoint in class EventDataSource

run

public void run()

Specified by:

run in interface java.lang.Runnable