com.serotonin.mango.rt.dataSource.galil

Class GalilDataSourceRT

java.lang.Object

com.serotonin.mango.rt.dataSource.DataSourceRT

com.serotonin.mango.rt.dataSource.PollingDataSource

com.serotonin.mango.rt.dataSource.galil.GalilDataSourceRT

All Implemented Interfaces:

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

public class GalilDataSourceRT
extends PollingDataSource
implements com.serotonin.messaging.MessagingExceptionHandler

Author:

Matthew Lohbihler

Field Summary

Fields

Modifier and Type	Field and Description
static java.nio.charset.Charset	CHARSET
private com.serotonin.messaging.MessageControl	conn
static int	DATA_SOURCE_EXCEPTION_EVENT
private org.apache.commons.logging.Log	LOG
static int	POINT_READ_EXCEPTION_EVENT
static int	POINT_WRITE_EXCEPTION_EVENT
private java.net.Socket	socket
private GalilDataSourceVO	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
GalilDataSourceRT(GalilDataSourceVO vo)

Method Summary

Modifier and Type	Method and Description
private void	closeConnection()
protected void	doPoll(long time)
void	initialize()
private void	openConnection()
void	receivedException(java.lang.Exception e)
void	receivedMessageMismatchException(java.lang.Exception e)
void	receivedResponseException(java.lang.Exception e)
private com.serotonin.web.i18n.LocalizableMessage	sendRequest(GalilRequest request, DataPointRT dataPoint, GalilPointLocatorRT locator, long time)
void	setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
void	terminate()

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

addDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentData

Methods inherited from class java.lang.Object

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

Field Detail

CHARSET

public static final java.nio.charset.Charset CHARSET

LOG

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

DATA_SOURCE_EXCEPTION_EVENT

public static final int DATA_SOURCE_EXCEPTION_EVENT

See Also:

Constant Field Values

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

vo

private final GalilDataSourceVO vo

socket

private java.net.Socket socket

conn

private com.serotonin.messaging.MessageControl conn

Constructor Detail

GalilDataSourceRT

public GalilDataSourceRT(GalilDataSourceVO vo)

Method Detail

doPoll

protected void doPoll(long time)

Specified by:

doPoll in class PollingDataSource

sendRequest

private com.serotonin.web.i18n.LocalizableMessage sendRequest(GalilRequest request,
                                                              DataPointRT dataPoint,
                                                              GalilPointLocatorRT locator,
                                                              long time)
                                                       throws java.io.IOException

Throws:

java.io.IOException

initialize

public void initialize()

Specified by:

initialize in interface com.serotonin.util.ILifecycle

Overrides:

initialize in class DataSourceRT

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

receivedException

public void receivedException(java.lang.Exception e)

Specified by:

receivedException in interface com.serotonin.messaging.MessagingExceptionHandler

receivedMessageMismatchException

public void receivedMessageMismatchException(java.lang.Exception e)

receivedResponseException

public void receivedResponseException(java.lang.Exception e)

openConnection

private void openConnection()
                     throws java.io.IOException

Throws:

java.io.IOException

closeConnection

private void closeConnection()