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, pointListChanged
addedChangedPoints, 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, updateChangedPoints
addDataPoint, forcePointRead, getExceptionMessage, getId, getName, getPersistentData, getSerialExceptionMessage, raiseEvent, relinquish, removeDataPoint, returnToNormal, setPersistentData
public 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.ILifecycle
initialize
in class DataSourceRT
public void terminate()
terminate
in interface com.serotonin.util.ILifecycle
terminate
in class PollingDataSource
protected void doPoll(long time)
doPoll
in class PollingDataSource
public void setPointValue(DataPointRT dataPoint, PointValueTime valueTime, SetPointSource source)
setPointValue
in class DataSourceRT
private void openServerConnection()
private void closeServerConnection()
private boolean updateDataPoint(DataPointRT dp)
private javax.management.MBeanAttributeInfo getAttributeInfo(javax.management.MBeanInfo info, java.lang.String attributeName)