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, pointListChanged
addedChangedPoints, 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, updateChangedPoints
addDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentData
private 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.ILifecycle
initialize
in class DataSourceRT
public void terminate()
terminate
in interface com.serotonin.util.ILifecycle
terminate
in class PollingDataSource
public double calcCorretedValue(DataPointRT point, double value)
protected void doPoll(long time)
doPoll
in class PollingDataSource
public void setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
setPointValue
in class DataSourceRT
private boolean openConnection()
private void closeConnection()