public class JmxDataSourceRT extends PollingDataSource
| Modifier and Type | Field and Description |
|---|---|
private javax.management.remote.JMXConnector |
connector |
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 javax.management.MBeanServerConnection |
server |
private JmxDataSourceVO |
vo |
dataPoints, pointListChangedaddedChangedPoints, ATTR_DISCONNECTED_KEY, ATTR_UNRELIABLE_KEY, pointListChangeLock, removedPoints| Constructor and Description |
|---|
JmxDataSourceRT(JmxDataSourceVO vo) |
| Modifier and Type | Method and Description |
|---|---|
private void |
closeServerConnection() |
protected void |
doPoll(long time) |
private javax.management.MBeanAttributeInfo |
getAttributeInfo(javax.management.MBeanInfo info,
java.lang.String attributeName) |
void |
initialize() |
private void |
openServerConnection() |
void |
setPointValue(DataPointRT dataPoint,
PointValueTime valueTime,
SetPointSource source) |
void |
terminate() |
private boolean |
updateDataPoint(DataPointRT dp) |
beginPolling, joinTermination, scheduleTimeout, setPollingPeriod, updateChangedPointsaddDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentDatapublic 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 org.apache.commons.logging.Log log
private final JmxDataSourceVO vo
private javax.management.remote.JMXConnector connector
private javax.management.MBeanServerConnection server
public JmxDataSourceRT(JmxDataSourceVO 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 PollingDataSourceprotected void doPoll(long time)
doPoll in class PollingDataSourcepublic void setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
setPointValue in class DataSourceRTprivate void openServerConnection()
private void closeServerConnection()
private boolean updateDataPoint(DataPointRT dp)
private javax.management.MBeanAttributeInfo getAttributeInfo(javax.management.MBeanInfo info,
java.lang.String attributeName)