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 |
dataPointsaddedChangedPoints, 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, setPersistentDataprivate 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.ILifecycleinitialize in class DataSourceRTpublic void addDataPoint(DataPointRT dataPoint)
addDataPoint in class EventDataSourcepublic void removeDataPoint(DataPointRT dataPoint)
removeDataPoint in class EventDataSourcepublic void terminate()
terminate in interface com.serotonin.util.ILifecycleterminate in class DataSourceRTpublic void viconicsNetworkStatus(boolean online)
viconicsNetworkStatus in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsDeviceAdded(com.serotonin.viconics.ViconicsDevice device)
viconicsDeviceAdded in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsDeviceStatus(com.serotonin.viconics.ViconicsDevice device,
boolean online)
viconicsDeviceStatus in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsDeviceRemoved(com.serotonin.viconics.ViconicsDevice device)
viconicsDeviceRemoved in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsReceivedException(java.lang.Exception e)
viconicsReceivedException in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsDevicePointUpdated(com.serotonin.viconics.ViconicsDevice device,
com.serotonin.viconics.config.StatPoint point,
int deviceValue,
long time)
viconicsDevicePointUpdated in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void viconicsDuplicateCommAddressDetected(int commAddress)
viconicsDuplicateCommAddressDetected in interface com.serotonin.viconics.ViconicsNetworkListenerpublic void setPointValue(DataPointRT dataPoint, PointValueTime pvt, SetPointSource source)
setPointValue in class EventDataSourcepublic void forcePointRead(DataPointRT dataPoint)
forcePointRead in class DataSourceRTpublic <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.ViconicsTransportExceptioncom.serotonin.viconics.RequestFailureExceptionpublic java.util.List<com.serotonin.viconics.ViconicsDevice> getDevices()