org.wso2.carbon.data.provider

Class AbstractDataProvider

java.lang.Object

org.wso2.carbon.data.provider.AbstractDataProvider

All Implemented Interfaces:

DataProvider

Direct Known Subclasses:

AbstractRDBMSDataProvider, SiddhiProvider

public abstract class AbstractDataProvider
extends Object
implements DataProvider

Abstract data provider class.

Constructor Summary

Constructors

Constructor and Description
AbstractDataProvider()

Method Summary

Modifier and Type	Method and Description
abstract boolean	configValidator(ProviderConfig providerConfig) Provider configuration validator.
abstract DataSetMetadata	getMetadata() Get the meta data of the RDBMS provider.
DataProvider	init(String topic, String sessionId, ProviderConfig providerConfig)
abstract void	publish(String topic, String sessionId)
void	publishToEndPoint(ArrayList<Object[]> data, String sessionId, String topic)
abstract void	purging()
abstract void	setProviderConfig(ProviderConfig providerConfig) Set the provider configuration, child class will be maintained its own provider configuration bean object.
void	start() Start pushing data to the client from the data sources.
void	stop() Stop pushing data to the client and disconnect.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.wso2.carbon.data.provider.DataProvider

dataSetMetadata, init, providerConfig, providerName

Constructor Detail

AbstractDataProvider

public AbstractDataProvider()

Method Detail

init

public DataProvider init(String topic,
                         String sessionId,
                         ProviderConfig providerConfig)
                  throws DataProviderException

Throws:

DataProviderException

stop

public void stop()

Description copied from interface: DataProvider

Stop pushing data to the client and disconnect.

Specified by:

stop in interface DataProvider

start

public void start()

Description copied from interface: DataProvider

Start pushing data to the client from the data sources.

Specified by:

start in interface DataProvider

publishToEndPoint

public void publishToEndPoint(ArrayList<Object[]> data,
                              String sessionId,
                              String topic)

configValidator

public abstract boolean configValidator(ProviderConfig providerConfig)
                                 throws DataProviderException

Description copied from interface: DataProvider

Provider configuration validator.

Specified by:

configValidator in interface DataProvider

Parameters:

providerConfig - provider configuration get from the client.

Returns:

validation results.

Throws:

DataProviderException - if the validation failed due to exception.

publish

public abstract void publish(String topic,
                             String sessionId)

purging

public abstract void purging()

setProviderConfig

public abstract void setProviderConfig(ProviderConfig providerConfig)

Set the provider configuration, child class will be maintained its own provider configuration bean object.

Parameters:

providerConfig - client provided configuration.

getMetadata

public abstract DataSetMetadata getMetadata()

Get the meta data of the RDBMS provider.

Returns:

rdbms meta data object.