com.serotonin.mango.rt.dataSource.modbus

Class ModbusDataSource

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.modbus.ModbusDataSource

All Implemented Interfaces:

TimeoutClient, com.serotonin.modbus4j.messaging.MessagingExceptionHandler, com.serotonin.util.ILifecycle

Direct Known Subclasses:

ModbusIpDataSource, ModbusSerialDataSource

public abstract class ModbusDataSource
extends PollingDataSource
implements com.serotonin.modbus4j.messaging.MessagingExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private com.serotonin.modbus4j.BatchRead<ModbusPointLocatorRT>	batchRead
static int	DATA_SOURCE_EXCEPTION_EVENT
private boolean	eventRaised
private org.apache.commons.logging.Log	LOG
private com.serotonin.modbus4j.ModbusMaster	modbusMaster
static int	POINT_READ_EXCEPTION_EVENT
static int	POINT_WRITE_EXCEPTION_EVENT
private java.util.Map<java.lang.Integer,DataPointRT>	slaveMonitors
private ModbusDataSourceVO<?>	vo

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

dataPoints, pointListChanged

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
ModbusDataSource(ModbusDataSourceVO<?> vo)

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(DataPointRT dataPoint)
static com.serotonin.modbus4j.locator.BaseLocator<?>	createModbusLocator(ModbusPointLocatorVO vo)
protected void	doPoll(long time)
void	forcePointRead(DataPointRT dataPoint)
protected com.serotonin.web.i18n.LocalizableMessage	getLocalExceptionMessage(java.lang.Exception e)
protected void	initialize(com.serotonin.modbus4j.ModbusMaster modbusMaster)
static com.serotonin.web.i18n.LocalizableMessage	localExceptionMessage(java.lang.Exception e)
void	receivedException(java.lang.Exception e)
void	removeDataPoint(DataPointRT dataPoint)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	terminate()
private void	updatePointValue(DataPointRT dataPoint, ModbusPointLocatorRT pl, java.lang.Object value, long time)

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

beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPoints

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

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private final org.apache.commons.logging.Log LOG

eventRaised

private boolean eventRaised

POINT_READ_EXCEPTION_EVENT

public static final int POINT_READ_EXCEPTION_EVENT

See Also:

Constant Field Values

POINT_WRITE_EXCEPTION_EVENT

public static final int POINT_WRITE_EXCEPTION_EVENT

See Also:

Constant Field Values

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

modbusMaster

private com.serotonin.modbus4j.ModbusMaster modbusMaster

batchRead

private com.serotonin.modbus4j.BatchRead<ModbusPointLocatorRT> batchRead

vo

private final ModbusDataSourceVO<?> vo

slaveMonitors

private final java.util.Map<java.lang.Integer,DataPointRT> slaveMonitors

Constructor Detail

ModbusDataSource

public ModbusDataSource(ModbusDataSourceVO<?> vo)

Method Detail

addDataPoint

public void addDataPoint(DataPointRT dataPoint)

Overrides:

addDataPoint in class DataSourceRT

removeDataPoint

public void removeDataPoint(DataPointRT dataPoint)

Overrides:

removeDataPoint in class DataSourceRT

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

initialize

protected void initialize(com.serotonin.modbus4j.ModbusMaster modbusMaster)

forcePointRead

public void forcePointRead(DataPointRT dataPoint)

Overrides:

forcePointRead in class DataSourceRT

updatePointValue

private void updatePointValue(DataPointRT dataPoint,
                              ModbusPointLocatorRT pl,
                              java.lang.Object value,
                              long time)

terminate

public void terminate()

Specified by:

terminate in interface com.serotonin.util.ILifecycle

Overrides:

terminate in class PollingDataSource

setPointValue

public void setPointValue(DataPointRT dataPoint,
                          PointValueTime valueTime,
                          SetPointSource source)

Specified by:

setPointValue in class DataSourceRT

createModbusLocator

public static com.serotonin.modbus4j.locator.BaseLocator<?> createModbusLocator(ModbusPointLocatorVO vo)

localExceptionMessage

public static com.serotonin.web.i18n.LocalizableMessage localExceptionMessage(java.lang.Exception e)

getLocalExceptionMessage

protected com.serotonin.web.i18n.LocalizableMessage getLocalExceptionMessage(java.lang.Exception e)

receivedException

public void receivedException(java.lang.Exception e)

Specified by:

receivedException in interface com.serotonin.modbus4j.messaging.MessagingExceptionHandler