org.eclipse.scada.ds.storage.file

Class StorageImpl

java.lang.Object

org.eclipse.scada.ds.storage.AbstractStorage

org.eclipse.scada.ds.storage.file.StorageImpl

All Implemented Interfaces:

DataStore

public class StorageImpl
extends AbstractStorage

Constructor Summary

Constructors

Constructor and Description
StorageImpl()

Method Summary

Modifier and Type	Method and Description
NotifyFuture<Void>	deleteNode(String nodeId)
void	dispose() Dispose the service.
protected Executor	getExecutor() Provide an executor for sending events
NotifyFuture<DataNode>	readNode(String nodeId) Get the data node
NotifyFuture<Void>	writeNode(DataNode node)

Methods inherited from class org.eclipse.scada.ds.storage.AbstractStorage

attachListener, detachListener, fireUpdate

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageImpl

public StorageImpl()
            throws IOException

Throws:

IOException

Method Detail

getExecutor

protected Executor getExecutor()

Description copied from class: AbstractStorage

Provide an executor for sending events

This method is only called after the constructor is completed

Specified by:

getExecutor in class AbstractStorage

Returns:

the executor to use, must never return null

dispose

public void dispose()

Description copied from class: AbstractStorage

Dispose the service.

This method still needs a valid executor using AbstractStorage.getExecutor().

Overrides:

dispose in class AbstractStorage

readNode

public NotifyFuture<DataNode> readNode(String nodeId)

Description copied from interface: DataStore

Get the data node

Specified by:

readNode in interface DataStore

Specified by:

readNode in class AbstractStorage

Parameters:

nodeId - the id of the node to get

Returns:

the future to the read request. The future will return null if the node does not exists.

writeNode

public NotifyFuture<Void> writeNode(DataNode node)

deleteNode

public NotifyFuture<Void> deleteNode(String nodeId)