public class ViconicsDataSourceRT extends EventDataSource implements com.serotonin.viconics.ViconicsNetworkListener
Modifier and Type | Class and Description |
---|---|
(package private) class |
ViconicsDataSourceRT.PointKey |
Modifier and Type | Field and Description |
---|---|
static int |
DEVICE_OFFLINE_EVENT |
static int |
DUPLICATE_COMM_ADDRESS_EVENT |
static int |
INITIALIZATION_EXCEPTION_EVENT |
private org.apache.commons.logging.Log |
log |
static int |
MESSAGE_EXCEPTION_EVENT |
private com.serotonin.viconics.ViconicsNetwork |
network |
static int |
NETWORK_OFFLINE_EVENT |
private java.lang.Object |
newDeviceLock |
private java.util.Map<ViconicsDataSourceRT.PointKey,DataPointRT> |
pointLookup |
private ViconicsDataSourceVO |
vo |
dataPoints
addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints
Constructor and Description |
---|
ViconicsDataSourceRT(ViconicsDataSourceVO vo) |
Modifier and Type | Method and Description |
---|---|
void |
addDataPoint(DataPointRT dataPoint) |
void |
forcePointRead(DataPointRT dataPoint) |
java.util.List<com.serotonin.viconics.ViconicsDevice> |
getDevices() |
void |
initialize() |
void |
removeDataPoint(DataPointRT dataPoint) |
<T extends com.serotonin.viconics.io.ViconicsIncomingResponse> |
send(com.serotonin.viconics.io.ViconicsOutgoingRequest request) |
void |
setPointValue(DataPointRT dataPoint,
PointValueTime pvt,
SetPointSource source) |
void |
terminate() |
void |
viconicsDeviceAdded(com.serotonin.viconics.ViconicsDevice device) |
void |
viconicsDevicePointUpdated(com.serotonin.viconics.ViconicsDevice device,
com.serotonin.viconics.config.StatPoint point,
int deviceValue,
long time) |
void |
viconicsDeviceRemoved(com.serotonin.viconics.ViconicsDevice device) |
void |
viconicsDeviceStatus(com.serotonin.viconics.ViconicsDevice device,
boolean online) |
void |
viconicsDuplicateCommAddressDetected(int commAddress) |
void |
viconicsNetworkStatus(boolean online) |
void |
viconicsReceivedException(java.lang.Exception e) |
beginPolling, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, joinTermination, raiseEvent, relinquish, returnToNormal, setPersistentData
private final java.lang.Object newDeviceLock
public static final int INITIALIZATION_EXCEPTION_EVENT
public static final int MESSAGE_EXCEPTION_EVENT
public static final int DEVICE_OFFLINE_EVENT
public static final int NETWORK_OFFLINE_EVENT
public static final int DUPLICATE_COMM_ADDRESS_EVENT
private final org.apache.commons.logging.Log log
private final ViconicsDataSourceVO vo
private com.serotonin.viconics.ViconicsNetwork network
private final java.util.Map<ViconicsDataSourceRT.PointKey,DataPointRT> pointLookup
public ViconicsDataSourceRT(ViconicsDataSourceVO vo)
public void initialize()
initialize
in interface com.serotonin.util.ILifecycle
initialize
in class DataSourceRT
public void addDataPoint(DataPointRT dataPoint)
addDataPoint
in class EventDataSource
public void removeDataPoint(DataPointRT dataPoint)
removeDataPoint
in class EventDataSource
public void terminate()
terminate
in interface com.serotonin.util.ILifecycle
terminate
in class DataSourceRT
public void viconicsNetworkStatus(boolean online)
viconicsNetworkStatus
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsDeviceAdded(com.serotonin.viconics.ViconicsDevice device)
viconicsDeviceAdded
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsDeviceStatus(com.serotonin.viconics.ViconicsDevice device, boolean online)
viconicsDeviceStatus
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsDeviceRemoved(com.serotonin.viconics.ViconicsDevice device)
viconicsDeviceRemoved
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsReceivedException(java.lang.Exception e)
viconicsReceivedException
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsDevicePointUpdated(com.serotonin.viconics.ViconicsDevice device, com.serotonin.viconics.config.StatPoint point, int deviceValue, long time)
viconicsDevicePointUpdated
in interface com.serotonin.viconics.ViconicsNetworkListener
public void viconicsDuplicateCommAddressDetected(int commAddress)
viconicsDuplicateCommAddressDetected
in interface com.serotonin.viconics.ViconicsNetworkListener
public void setPointValue(DataPointRT dataPoint, PointValueTime pvt, SetPointSource source)
setPointValue
in class EventDataSource
public void forcePointRead(DataPointRT dataPoint)
forcePointRead
in class DataSourceRT
public <T extends com.serotonin.viconics.io.ViconicsIncomingResponse> T send(com.serotonin.viconics.io.ViconicsOutgoingRequest request) throws com.serotonin.viconics.ViconicsTransportException, com.serotonin.viconics.RequestFailureException
com.serotonin.viconics.ViconicsTransportException
com.serotonin.viconics.RequestFailureException
public java.util.List<com.serotonin.viconics.ViconicsDevice> getDevices()