org.kaaproject.kaa.client.configuration.manager

Class DefaultConfigurationManager

java.lang.Object

org.kaaproject.kaa.client.configuration.manager.DefaultConfigurationManager

All Implemented Interfaces:

ConfigurationProcessedObserver, GenericDeltaReceiver, ConfigurationManager

public class DefaultConfigurationManager
extends Object
implements GenericDeltaReceiver, ConfigurationManager, ConfigurationProcessedObserver

Default @{link ConfigurationManager} implementation

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
DefaultConfigurationManager()

Method Summary

Methods

Modifier and Type	Method and Description
CommonRecord	getConfiguration() Retrieves full configuration
void	onConfigurationProcessed() Notify about configuration processing is finished.
void	onDeltaReceived(int index, org.apache.avro.generic.GenericRecord data, boolean fullResync) Called on each deserialized delta
void	subscribeForConfigurationUpdates(ConfigurationReceiver receiver) Subscribes for configuration updates. NOTE: Attempting to subscribe two instances of ConfigurationReceiver such as receiver1.equals(receiver2) == true will result the fact that only first instance will be subscribed.
void	unsubscribeFromConfigurationUpdates(ConfigurationReceiver receiver) Unsubscribes from configuration updates. NOTE: Attempting to unsubscribe object which was not subscribed previously will not make any effect.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConfigurationManager

public DefaultConfigurationManager()

Method Detail

onDeltaReceived

public void onDeltaReceived(int index,
                   org.apache.avro.generic.GenericRecord data,
                   boolean fullResync)

Description copied from interface: GenericDeltaReceiver

Called on each deserialized delta

Specified by:

onDeltaReceived in interface GenericDeltaReceiver

Parameters:

index - Index of the current delta in the union list

data - Avro generic object with deserialized delta

fullResync - Tells if current delta is a full resync

onConfigurationProcessed

public void onConfigurationProcessed()

Description copied from interface: ConfigurationProcessedObserver

Notify about configuration processing is finished.

Specified by:

onConfigurationProcessed in interface ConfigurationProcessedObserver

subscribeForConfigurationUpdates

public void subscribeForConfigurationUpdates(ConfigurationReceiver receiver)

Description copied from interface: ConfigurationManager

Subscribes for configuration updates.

NOTE: Attempting to subscribe two instances of ConfigurationReceiver such as receiver1.equals(receiver2) == true will result the fact that only first instance will be subscribed.

Specified by:

subscribeForConfigurationUpdates in interface ConfigurationManager

Parameters:

receiver - object to receive updates

See Also:

ConfigurationReceiver

unsubscribeFromConfigurationUpdates

public void unsubscribeFromConfigurationUpdates(ConfigurationReceiver receiver)

Description copied from interface: ConfigurationManager

Unsubscribes from configuration updates.

NOTE: Attempting to unsubscribe object which was not subscribed previously will not make any effect.

Specified by:

unsubscribeFromConfigurationUpdates in interface ConfigurationManager

Parameters:

receiver - object which is no longer needs configuration updates

See Also:

ConfigurationReceiver

getConfiguration

public CommonRecord getConfiguration()

Description copied from interface: ConfigurationManager

Retrieves full configuration

Specified by:

getConfiguration in interface ConfigurationManager

Returns:

common object with full configuration

See Also:

CommonRecord