public class DefaultDeltaManager extends Object implements DeltaManager, GenericDeltaReceiver
DeltaManager
implementationConstructor and Description |
---|
DefaultDeltaManager() |
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.
|
public void onDeltaReceived(int index, org.apache.avro.generic.GenericRecord data, boolean fullResync)
GenericDeltaReceiver
onDeltaReceived
in interface GenericDeltaReceiver
index
- Index of the current delta in the union listdata
- Avro generic object with deserialized deltafullResync
- Tells if current delta is a full resyncpublic void registerRootReceiver(DeltaReceiver rootReceiver)
DeltaManager
registerRootReceiver
in interface DeltaManager
rootReceiver
- the root receiver objectDeltaReceiver
public void subscribeForDeltaUpdates(DeltaHandlerId handlerId, DeltaReceiver receiver)
DeltaManager
subscribeForDeltaUpdates
in interface DeltaManager
handlerId
- id of the delta handlerreceiver
- the object to receive updatesDeltaHandlerId
,
DeltaReceiver
public void unsubscribeFromDeltaUpdates(DeltaHandlerId handlerId)
DeltaManager
unsubscribeFromDeltaUpdates
in interface DeltaManager
handlerId
- id of the handler to be unsubscribedDeltaHandlerId
Copyright © 2014. All rights reserved.