public class NmeaDataSourceRT extends EventDataSource implements NmeaMessageListener, TimeoutClient
Modifier and Type | Field and Description |
---|---|
static int |
DATA_SOURCE_EXCEPTION_EVENT |
private org.apache.commons.logging.Log |
log |
private NmeaReceiver |
nmeaReceiver |
static int |
PARSE_EXCEPTION_EVENT |
private com.serotonin.timer.TimerTask |
resetTask |
private NmeaDataSourceVO |
vo |
dataPoints
addedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints
Constructor and Description |
---|
NmeaDataSourceRT(NmeaDataSourceVO vo) |
Modifier and Type | Method and Description |
---|---|
void |
initialize() |
private boolean |
initNmea() |
void |
receivedException(java.lang.Exception e) |
void |
receivedMessage(NmeaMessage message) |
private void |
receivedMessageImpl(DataPointRT dp,
NmeaMessage message,
long time) |
private void |
scheduleTimeout() |
void |
scheduleTimeout(long fireTime) |
void |
terminate() |
private void |
termNmea() |
private void |
unscheduleTimeout() |
addDataPoint, removeDataPoint, setPointValue
beginPolling, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, joinTermination, raiseEvent, relinquish, returnToNormal, setPersistentData
public static final int DATA_SOURCE_EXCEPTION_EVENT
public static final int PARSE_EXCEPTION_EVENT
private final org.apache.commons.logging.Log log
private final NmeaDataSourceVO vo
private NmeaReceiver nmeaReceiver
private com.serotonin.timer.TimerTask resetTask
public NmeaDataSourceRT(NmeaDataSourceVO 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 DataSourceRT
private boolean initNmea()
private void termNmea()
public void receivedException(java.lang.Exception e)
receivedException
in interface com.serotonin.messaging.MessagingExceptionHandler
public void receivedMessage(NmeaMessage message)
receivedMessage
in interface NmeaMessageListener
private void receivedMessageImpl(DataPointRT dp, NmeaMessage message, long time) throws java.lang.Exception
java.lang.Exception
public void scheduleTimeout(long fireTime)
scheduleTimeout
in interface TimeoutClient
private void scheduleTimeout()
private void unscheduleTimeout()