public class MBusDataSourceRT extends PollingDataSource
| Modifier and Type | Field and Description |
|---|---|
static int |
DATA_SOURCE_EXCEPTION_EVENT |
private static org.apache.commons.logging.Log |
LOG |
private net.sf.mbus4j.master.MBusMaster |
master |
static int |
POINT_READ_EXCEPTION_EVENT |
static int |
POINT_WRITE_EXCEPTION_EVENT |
private MBusDataSourceVO |
vo |
dataPoints, pointListChangedaddedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints| Constructor and Description |
|---|
MBusDataSourceRT(MBusDataSourceVO vo) |
| Modifier and Type | Method and Description |
|---|---|
double |
calcCorretedValue(DataPointRT point,
double value) |
private void |
closeConnection() |
protected void |
doPoll(long time) |
void |
initialize() |
private boolean |
openConnection() |
void |
setPointValue(DataPointRT dataPoint,
PointValueTime valueTime,
SetPointSource source) |
void |
terminate() |
beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPointsaddDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentDataprivate static final org.apache.commons.logging.Log LOG
public static final int DATA_SOURCE_EXCEPTION_EVENT
public static final int POINT_READ_EXCEPTION_EVENT
public static final int POINT_WRITE_EXCEPTION_EVENT
private final MBusDataSourceVO vo
private final net.sf.mbus4j.master.MBusMaster master
public MBusDataSourceRT(MBusDataSourceVO vo)
public void initialize()
initialize in interface com.serotonin.util.ILifecycleinitialize in class DataSourceRTpublic void terminate()
terminate in interface com.serotonin.util.ILifecycleterminate in class PollingDataSourcepublic double calcCorretedValue(DataPointRT point, double value)
protected void doPoll(long time)
doPoll in class PollingDataSourcepublic void setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
setPointValue in class DataSourceRTprivate boolean openConnection()
private void closeConnection()