org.kaaproject.kaa.client.configuration.delta.manager

Class DefaultDeltaManager

java.lang.Object

org.kaaproject.kaa.client.configuration.delta.manager.DefaultDeltaManager

All Implemented Interfaces:

DeltaManager, GenericDeltaReceiver

public class DefaultDeltaManager
extends Object
implements DeltaManager, GenericDeltaReceiver

Default DeltaManager implementation

Author:

Yaroslav Zeygerman

Constructor Summary

Constructors

Constructor and Description
DefaultDeltaManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	onDeltaReceived(int index, org.apache.avro.generic.GenericRecord data, boolean fullResync) Called on each deserialized delta
void	registerRootReceiver(DeltaReceiver rootReceiver) Registers root receiver to receive first and full resync deltas.
void	subscribeForDeltaUpdates(DeltaHandlerId handlerId, DeltaReceiver receiver) Subscribes receiver for delta updates by the given handler id.
void	unsubscribeFromDeltaUpdates(DeltaHandlerId handlerId) Unsubscribes receiver from delta updates.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDeltaManager

public DefaultDeltaManager()

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

registerRootReceiver

public void registerRootReceiver(DeltaReceiver rootReceiver)

Description copied from interface: DeltaManager

Registers root receiver to receive first and full resync deltas.

Specified by:

registerRootReceiver in interface DeltaManager

Parameters:

rootReceiver - the root receiver object

See Also:

DeltaReceiver

subscribeForDeltaUpdates

public void subscribeForDeltaUpdates(DeltaHandlerId handlerId,
                            DeltaReceiver receiver)

Description copied from interface: DeltaManager

Subscribes receiver for delta updates by the given handler id.

Specified by:

subscribeForDeltaUpdates in interface DeltaManager

Parameters:

handlerId - id of the delta handler

receiver - the object to receive updates

See Also:

DeltaHandlerId, DeltaReceiver

unsubscribeFromDeltaUpdates

public void unsubscribeFromDeltaUpdates(DeltaHandlerId handlerId)

Description copied from interface: DeltaManager

Unsubscribes receiver from delta updates.

Specified by:

unsubscribeFromDeltaUpdates in interface DeltaManager

Parameters:

handlerId - id of the handler to be unsubscribed

See Also:

DeltaHandlerId