org.kaaproject.kaa.client.configuration

Class DefaultConfigurationProcessor

java.lang.Object

org.kaaproject.kaa.client.configuration.DefaultConfigurationProcessor

All Implemented Interfaces:

ConfigurationProcessedObservable, ConfigurationProcessor, DecodedDeltaObservable, SchemaUpdatesReceiver

public class DefaultConfigurationProcessor
extends Object
implements ConfigurationProcessor, DecodedDeltaObservable, SchemaUpdatesReceiver, ConfigurationProcessedObservable

Implementation of ConfigurationProcessor using avro decoding mechanisms

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
DefaultConfigurationProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
void	addOnProcessedCallback(ConfigurationProcessedObserver callback) Subscribes observer of configuration processing finished.
void	onSchemaUpdated(org.apache.avro.Schema schema) Called on each schema update
void	processConfigurationData(ByteBuffer buffer, boolean fullResync) Routine for processing received configuration data.
void	removeOnProcessedCallback(ConfigurationProcessedObserver callback) Unsubscribes observer of configuration processing finished.
void	subscribeForUpdates(GenericDeltaReceiver receiver) Subscribes new receiver for decoded data updates
void	unsubscribeFromUpdates(GenericDeltaReceiver receiver) Unsubscribes receiver from decoded data updates

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultConfigurationProcessor

public DefaultConfigurationProcessor()

Method Detail

processConfigurationData

public void processConfigurationData(ByteBuffer buffer,
                            boolean fullResync)
                              throws IOException

Description copied from interface: ConfigurationProcessor

Routine for processing received configuration data.

Specified by:

processConfigurationData in interface ConfigurationProcessor

Parameters:

buffer - The input buffer with raw data

fullResync - Notify whether configuration is a full resync

Throws:

IOException

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

subscribeForUpdates

public void subscribeForUpdates(GenericDeltaReceiver receiver)

Description copied from interface: DecodedDeltaObservable

Subscribes new receiver for decoded data updates

Specified by:

subscribeForUpdates in interface DecodedDeltaObservable

Parameters:

receiver - receiver to get decoded configuration updates

See Also:

GenericDeltaReceiver

unsubscribeFromUpdates

public void unsubscribeFromUpdates(GenericDeltaReceiver receiver)

Description copied from interface: DecodedDeltaObservable

Unsubscribes receiver from decoded data updates

Specified by:

unsubscribeFromUpdates in interface DecodedDeltaObservable

Parameters:

receiver - receiver to be unsubscribed from configuration updates

See Also:

GenericDeltaReceiver

addOnProcessedCallback

public void addOnProcessedCallback(ConfigurationProcessedObserver callback)

Description copied from interface: ConfigurationProcessedObservable

Subscribes observer of configuration processing finished.

Specified by:

addOnProcessedCallback in interface ConfigurationProcessedObservable

Parameters:

callback - Receiver to be subscribed.

See Also:

ConfigurationProcessedObserver

removeOnProcessedCallback

public void removeOnProcessedCallback(ConfigurationProcessedObserver callback)

Description copied from interface: ConfigurationProcessedObservable

Unsubscribes observer of configuration processing finished.

Specified by:

removeOnProcessedCallback in interface ConfigurationProcessedObservable

Parameters:

callback - Receiver to be unsubscribed.

See Also:

ConfigurationProcessedObserver