org.dsa.iot.historian.database

Class WatchGroup

java.lang.Object

org.dsa.iot.historian.database.WatchGroup

public class WatchGroup
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
WatchGroup(org.dsa.iot.dslink.node.Permission perm, org.dsa.iot.dslink.node.Node node, Database db)

Method Summary

Modifier and Type	Method and Description
void	addWatch(Watch watch)
void	addWatchUpdateToBuffer(WatchUpdate watchUpdate, java.util.Date date)
void	cancelIntervalScheduler()
boolean	canWriteOnNewData()
void	close()
Database	getDb() Watches should never write data to the database directly unless absolutely necessary.
protected void	initSettings()
protected void	initWatch(java.lang.String path, boolean useNewEncodingMethod) Initializes the watch for the group.
void	removeFromWatches(Watch watch)
void	subscribe() Subscribes to the entire watch group.
void	unsubscribe() Unsubscribes from the entire watch group.
void	write(Watch watch, org.dsa.iot.dslink.node.value.SubscriptionValue sv) Writes to the database based on the watch group settings.

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchGroup

public WatchGroup(org.dsa.iot.dslink.node.Permission perm,
                  org.dsa.iot.dslink.node.Node node,
                  Database db)

Parameters:

perm - Permission all actions should be set to.

node - Watch group node.

db - Database the group writes to.

Method Detail

close

public void close()

getDb

public Database getDb()

Watches should never write data to the database directly unless absolutely necessary.

Returns:

The database the group operates on.

write

public void write(Watch watch,
                  org.dsa.iot.dslink.node.value.SubscriptionValue sv)

Writes to the database based on the watch group settings.

Parameters:

watch - Watch to write from.

sv - Subscription update received from the server.

initWatch

protected void initWatch(java.lang.String path,
                         boolean useNewEncodingMethod)

Initializes the watch for the group.

Parameters:

path - Watch path.

useNewEncodingMethod -

subscribe

public void subscribe()

Subscribes to the entire watch group.

unsubscribe

public void unsubscribe()

Unsubscribes from the entire watch group.

initSettings

protected void initSettings()

canWriteOnNewData

public boolean canWriteOnNewData()

addWatchUpdateToBuffer

public void addWatchUpdateToBuffer(WatchUpdate watchUpdate,
                                   java.util.Date date)

cancelIntervalScheduler

public void cancelIntervalScheduler()

addWatch

public void addWatch(Watch watch)

removeFromWatches

public void removeFromWatches(Watch watch)