org.eclipse.scada.da.datasource.proxy.internal

Class ProxyDataSource

java.lang.Object

org.eclipse.scada.da.datasource.base.AbstractDataSource

org.eclipse.scada.da.datasource.proxy.internal.ProxyDataSource

All Implemented Interfaces:

DataSource, MultiDataSourceTracker.ServiceListener

public class ProxyDataSource
extends AbstractDataSource
implements MultiDataSourceTracker.ServiceListener

Field Summary

Fields inherited from interface org.eclipse.scada.da.datasource.DataSource

DATA_SOURCE_ID

Constructor Summary

Constructors

Constructor and Description
ProxyDataSource(ObjectPoolTracker<DataSource> poolTracker, Executor executor)

Method Summary

Modifier and Type	Method and Description
void	dataSourceAdded(String id, Dictionary<?,?> properties, DataSource dataSource)
void	dataSourceModified(String id, Dictionary<?,?> properties, DataSource dataSource)
void	dataSourceRemoved(String id, Dictionary<?,?> properties, DataSource dataSource)
void	dispose()
protected Executor	getExecutor() Return the executor to use for sending out events
NotifyFuture<WriteAttributeResults>	startWriteAttributes(Map<String,Variant> attributes, OperationParameters operationParameters)
NotifyFuture<WriteResult>	startWriteValue(Variant value, OperationParameters operationParameters)
protected void	update()
void	update(Map<String,String> properties)

Methods inherited from class org.eclipse.scada.da.datasource.base.AbstractDataSource

addListener, removeListener, updateData

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyDataSource

public ProxyDataSource(ObjectPoolTracker<DataSource> poolTracker,
                       Executor executor)

Method Detail

getExecutor

protected Executor getExecutor()

Description copied from class: AbstractDataSource

Return the executor to use for sending out events

Specified by:

getExecutor in class AbstractDataSource

Returns:

the executor to use, must never be null

dispose

public void dispose()

update

public void update(Map<String,String> properties)
            throws Exception

Throws:

Exception

update

protected void update()

startWriteAttributes

public NotifyFuture<WriteAttributeResults> startWriteAttributes(Map<String,Variant> attributes,
                                                                OperationParameters operationParameters)

Specified by:

startWriteAttributes in interface DataSource

startWriteValue

public NotifyFuture<WriteResult> startWriteValue(Variant value,
                                                 OperationParameters operationParameters)

Specified by:

startWriteValue in interface DataSource

dataSourceAdded

public void dataSourceAdded(String id,
                            Dictionary<?,?> properties,
                            DataSource dataSource)

Specified by:

dataSourceAdded in interface MultiDataSourceTracker.ServiceListener

dataSourceModified

public void dataSourceModified(String id,
                               Dictionary<?,?> properties,
                               DataSource dataSource)

Specified by:

dataSourceModified in interface MultiDataSourceTracker.ServiceListener

dataSourceRemoved

public void dataSourceRemoved(String id,
                              Dictionary<?,?> properties,
                              DataSource dataSource)

Specified by:

dataSourceRemoved in interface MultiDataSourceTracker.ServiceListener