com.serotonin.mango.rt.dataSource.meta

Class MetaPointLocatorRT

java.lang.Object

com.serotonin.mango.rt.dataSource.PointLocatorRT

com.serotonin.mango.rt.dataSource.meta.MetaPointLocatorRT

All Implemented Interfaces:

DataPointListener

Direct Known Subclasses:

HistoricalMetaPointLocatorRT

public class MetaPointLocatorRT
extends PointLocatorRT
implements DataPointListener

Author:

Matthew Lohbihler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	MetaPointLocatorRT.ExecutionDelayTimeout
(package private) class	MetaPointLocatorRT.ScheduledUpdateTimeout

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.String,IDataPoint>	context
protected DataPointRT	dataPoint
private MetaDataSourceRT	dataSource
(package private) boolean	initialized
(package private) java.lang.Boolean	LOCK
private static int	MAX_RECURSION
private static java.lang.ThreadLocal<java.util.List<java.lang.Integer>>	threadLocal
(package private) com.serotonin.timer.AbstractTimer	timer
(package private) com.serotonin.timer.TimerTask	timerTask
(package private) MetaPointLocatorVO	vo

Constructor Summary

Constructors

Constructor and Description
MetaPointLocatorRT(MetaPointLocatorVO vo)

Method Summary

Modifier and Type	Method and Description
(package private) long	calculateTimeout(long time)
private void	createContext()
(package private) void	execute(long runtime, java.util.List<java.lang.Integer> sourceIds)
MetaPointLocatorVO	getPointLocatorVO()
protected void	handleError(long runtime, com.serotonin.web.i18n.LocalizableMessage message)
void	initialize(com.serotonin.timer.AbstractTimer timer, MetaDataSourceRT dataSource, DataPointRT dataPoint)
protected void	initializeTimerTask()
(package private) boolean	isContextCreated()
boolean	isSettable()
void	pointBackdated(PointValueTime value) This method is called when a backdated value is received.
void	pointChanged(PointValueTime oldValue, PointValueTime newValue) This method is called every time the point gets a value that is different from its previous value (except for its initialization).
void	pointInitialized() This method is called for all existing listeners when the point is initialized.
void	pointSet(PointValueTime oldValue, PointValueTime newValue) This method is called every time the point gets set, whether the value changes or not.
void	pointTerminated() This method is called when the point has been terminated, allowing listeners to react as necessary.
void	pointUpdated(PointValueTime newValue) This method is called every time the point gets a value from somewhere (except for its initialization).
void	terminate()
protected void	updatePoint(PointValueTime pvt)

Methods inherited from class com.serotonin.mango.rt.dataSource.PointLocatorRT

isRelinquishable

Methods inherited from class java.lang.Object

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

Field Detail

threadLocal

private static final java.lang.ThreadLocal<java.util.List<java.lang.Integer>> threadLocal

MAX_RECURSION

private static final int MAX_RECURSION

See Also:

Constant Field Values

LOCK

final java.lang.Boolean LOCK

vo

final MetaPointLocatorVO vo

timer

com.serotonin.timer.AbstractTimer timer

dataSource

private MetaDataSourceRT dataSource

dataPoint

protected DataPointRT dataPoint

context

protected java.util.Map<java.lang.String,IDataPoint> context

initialized

boolean initialized

timerTask

com.serotonin.timer.TimerTask timerTask

Constructor Detail

MetaPointLocatorRT

public MetaPointLocatorRT(MetaPointLocatorVO vo)

Method Detail

isSettable

public boolean isSettable()

Specified by:

isSettable in class PointLocatorRT

getPointLocatorVO

public MetaPointLocatorVO getPointLocatorVO()

isContextCreated

boolean isContextCreated()

initialize

public void initialize(com.serotonin.timer.AbstractTimer timer,
                       MetaDataSourceRT dataSource,
                       DataPointRT dataPoint)

initializeTimerTask

protected void initializeTimerTask()

terminate

public void terminate()

pointChanged

public void pointChanged(PointValueTime oldValue,
                         PointValueTime newValue)

Description copied from interface: DataPointListener

This method is called every time the point gets a value that is different from its previous value (except for its initialization). This includes when the point is set, if the set changes the point's value.

Specified by:

pointChanged in interface DataPointListener

pointSet

public void pointSet(PointValueTime oldValue,
                     PointValueTime newValue)

Description copied from interface: DataPointListener

This method is called every time the point gets set, whether the value changes or not.

Specified by:

pointSet in interface DataPointListener

pointUpdated

public void pointUpdated(PointValueTime newValue)

Description copied from interface: DataPointListener

This method is called every time the point gets a value from somewhere (except for its initialization). This includes when the point changes or is set.

Specified by:

pointUpdated in interface DataPointListener

pointBackdated

public void pointBackdated(PointValueTime value)

Description copied from interface: DataPointListener

This method is called when a backdated value is received.

Specified by:

pointBackdated in interface DataPointListener

pointInitialized

public void pointInitialized()

Description copied from interface: DataPointListener

This method is called for all existing listeners when the point is initialized. Note that it is not called for listeners that have begun listening to an already-initialized point.

Specified by:

pointInitialized in interface DataPointListener

pointTerminated

public void pointTerminated()

Description copied from interface: DataPointListener

This method is called when the point has been terminated, allowing listeners to react as necessary.

Specified by:

pointTerminated in interface DataPointListener

calculateTimeout

long calculateTimeout(long time)

execute

void execute(long runtime,
             java.util.List<java.lang.Integer> sourceIds)

createContext

private void createContext()

updatePoint

protected void updatePoint(PointValueTime pvt)

handleError

protected void handleError(long runtime,
                           com.serotonin.web.i18n.LocalizableMessage message)