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 |
dataPointsaddedChangedPoints, 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, setPointValuebeginPolling, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, joinTermination, raiseEvent, relinquish, returnToNormal, setPersistentDatapublic 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.ILifecycleinitialize in class DataSourceRTpublic void terminate()
terminate in interface com.serotonin.util.ILifecycleterminate in class DataSourceRTprivate boolean initNmea()
private void termNmea()
public void receivedException(java.lang.Exception e)
receivedException in interface com.serotonin.messaging.MessagingExceptionHandlerpublic void receivedMessage(NmeaMessage message)
receivedMessage in interface NmeaMessageListenerprivate void receivedMessageImpl(DataPointRT dp, NmeaMessage message, long time) throws java.lang.Exception
java.lang.Exceptionpublic void scheduleTimeout(long fireTime)
scheduleTimeout in interface TimeoutClientprivate void scheduleTimeout()
private void unscheduleTimeout()