org.dsa.iot.historian.database

Class Watch

java.lang.Object

org.dsa.iot.historian.database.Watch

public class Watch
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	USE_NEW_ENCODING_METHOD_CONFIG_NAME

Constructor Summary

Constructors

Constructor and Description
Watch(WatchGroup group, org.dsa.iot.dslink.node.Node node)

Method Summary

Modifier and Type	Method and Description
void	addGetHistoryActionAlias()
void	addHandler(org.dsa.iot.dslink.util.handler.Handler<QueryData> handler)
WatchGroup	getGroup()
org.dsa.iot.dslink.node.value.Value	getLastValue()
WatchUpdate	getLastWatchUpdate()
long	getLastWrittenTime()
org.dsa.iot.dslink.node.Node	getNode()
java.lang.String	getPath()
void	handleLastWritten(org.dsa.iot.dslink.node.value.Value value)
void	init(org.dsa.iot.dslink.node.Permission perm, Database db)
protected void	initData(org.dsa.iot.dslink.node.Node node)
boolean	isEnabled()
void	notifyHandlers(QueryData data)
void	onData(org.dsa.iot.dslink.node.value.SubscriptionValue sv) Called when the watch receives data.
void	removeHandler(org.dsa.iot.dslink.util.handler.Handler<QueryData> handler)
void	setLastValue(org.dsa.iot.dslink.node.value.Value value)
void	setLastWrittenTime(long time)
void	unsubscribe()

Methods inherited from class java.lang.Object

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

Field Detail

USE_NEW_ENCODING_METHOD_CONFIG_NAME

public static final java.lang.String USE_NEW_ENCODING_METHOD_CONFIG_NAME

See Also:

Constant Field Values

Constructor Detail

Watch

public Watch(WatchGroup group,
             org.dsa.iot.dslink.node.Node node)

Method Detail

getLastWatchUpdate

public WatchUpdate getLastWatchUpdate()

getNode

public org.dsa.iot.dslink.node.Node getNode()

getGroup

public WatchGroup getGroup()

isEnabled

public boolean isEnabled()

getPath

public java.lang.String getPath()

handleLastWritten

public void handleLastWritten(org.dsa.iot.dslink.node.value.Value value)

setLastWrittenTime

public void setLastWrittenTime(long time)

getLastWrittenTime

public long getLastWrittenTime()

setLastValue

public void setLastValue(org.dsa.iot.dslink.node.value.Value value)

getLastValue

public org.dsa.iot.dslink.node.value.Value getLastValue()

unsubscribe

public void unsubscribe()

init

public void init(org.dsa.iot.dslink.node.Permission perm,
                 Database db)

addGetHistoryActionAlias

public void addGetHistoryActionAlias()

initData

protected void initData(org.dsa.iot.dslink.node.Node node)

onData

public void onData(org.dsa.iot.dslink.node.value.SubscriptionValue sv)

Called when the watch receives data.

Parameters:

sv - Received data.

addHandler

public void addHandler(org.dsa.iot.dslink.util.handler.Handler<QueryData> handler)

removeHandler

public void removeHandler(org.dsa.iot.dslink.util.handler.Handler<QueryData> handler)

notifyHandlers

public void notifyHandlers(QueryData data)