org.kaaproject.kaa.client.configuration.storage

Class DefaultConfigurationPersistenceManager

java.lang.Object

org.kaaproject.kaa.client.configuration.storage.DefaultConfigurationPersistenceManager

All Implemented Interfaces:

ConfigurationHashContainer, ConfigurationReceiver, ConfigurationPersistenceManager, SchemaUpdatesReceiver

public class DefaultConfigurationPersistenceManager
extends Object
implements ConfigurationPersistenceManager, ConfigurationReceiver, SchemaUpdatesReceiver, ConfigurationHashContainer

Default ConfigurationPersistenceManager implementation

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
DefaultConfigurationPersistenceManager()
DefaultConfigurationPersistenceManager(ConfigurationProcessor processor)
DefaultConfigurationPersistenceManager(org.apache.avro.Schema schema, ConfigurationProcessor processor)

Method Summary

Methods

Modifier and Type	Method and Description
org.kaaproject.kaa.common.hash.EndpointObjectHash	getConfigurationHash() Retrieves configuration data hash.
void	onConfigurationUpdated(CommonRecord configuration) This callback will be called on any configuration update
void	onSchemaUpdated(org.apache.avro.Schema schema) Called on each schema update
void	setConfigurationProcessor(ConfigurationProcessor processor)
void	setConfigurationStorage(ConfigurationStorage storage) Provide storage object which is able to persist encoded configuration data.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConfigurationPersistenceManager

public DefaultConfigurationPersistenceManager()

DefaultConfigurationPersistenceManager

public DefaultConfigurationPersistenceManager(org.apache.avro.Schema schema,
                                      ConfigurationProcessor processor)

DefaultConfigurationPersistenceManager

public DefaultConfigurationPersistenceManager(ConfigurationProcessor processor)

Method Detail

onConfigurationUpdated

public void onConfigurationUpdated(CommonRecord configuration)

Description copied from interface: ConfigurationReceiver

This callback will be called on any configuration update

Specified by:

onConfigurationUpdated in interface ConfigurationReceiver

Parameters:

configuration - full configuration in common objects

See Also:

CommonRecord

setConfigurationStorage

public void setConfigurationStorage(ConfigurationStorage storage)
                             throws IOException

Description copied from interface: ConfigurationPersistenceManager

Provide storage object which is able to persist encoded configuration data.

Specified by:

setConfigurationStorage in interface ConfigurationPersistenceManager

Parameters:

storage - Object which will save and load configuration data

Throws:

IOException

See Also:

ConfigurationStorage

setConfigurationProcessor

public void setConfigurationProcessor(ConfigurationProcessor processor)

onSchemaUpdated

public void onSchemaUpdated(org.apache.avro.Schema schema)

Description copied from interface: SchemaUpdatesReceiver

Called on each schema update

Specified by:

onSchemaUpdated in interface SchemaUpdatesReceiver

Parameters:

schema - new schema

getConfigurationHash

public org.kaaproject.kaa.common.hash.EndpointObjectHash getConfigurationHash()

Description copied from interface: ConfigurationHashContainer

Retrieves configuration data hash.

Specified by:

getConfigurationHash in interface ConfigurationHashContainer

See Also:

EndpointObjectHash