public class DefaultConfigurationProcessor extends Object implements ConfigurationProcessor, DecodedDeltaObservable, SchemaUpdatesReceiver, ConfigurationProcessedObservable
ConfigurationProcessor
using avro decoding mechanismsConstructor and Description |
---|
DefaultConfigurationProcessor() |
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
|
public void processConfigurationData(ByteBuffer buffer, boolean fullResync) throws IOException
ConfigurationProcessor
processConfigurationData
in interface ConfigurationProcessor
buffer
- The input buffer with raw datafullResync
- Notify whether configuration is a full resyncIOException
public void onSchemaUpdated(org.apache.avro.Schema schema)
SchemaUpdatesReceiver
onSchemaUpdated
in interface SchemaUpdatesReceiver
schema
- new schemapublic void subscribeForUpdates(GenericDeltaReceiver receiver)
DecodedDeltaObservable
subscribeForUpdates
in interface DecodedDeltaObservable
receiver
- receiver to get decoded configuration updatesGenericDeltaReceiver
public void unsubscribeFromUpdates(GenericDeltaReceiver receiver)
DecodedDeltaObservable
unsubscribeFromUpdates
in interface DecodedDeltaObservable
receiver
- receiver to be unsubscribed from configuration updatesGenericDeltaReceiver
public void addOnProcessedCallback(ConfigurationProcessedObserver callback)
ConfigurationProcessedObservable
addOnProcessedCallback
in interface ConfigurationProcessedObservable
callback
- Receiver to be subscribed.ConfigurationProcessedObserver
public void removeOnProcessedCallback(ConfigurationProcessedObserver callback)
ConfigurationProcessedObservable
removeOnProcessedCallback
in interface ConfigurationProcessedObservable
callback
- Receiver to be unsubscribed.ConfigurationProcessedObserver
Copyright © 2014. All rights reserved.