17 #ifndef CONFIGURATION_PROCESSOR_HPP_
18 #define CONFIGURATION_PROCESSOR_HPP_
20 #include <boost/cstdint.hpp>
21 #include <boost/signals2.hpp>
22 #include <boost/smart_ptr/shared_ptr.hpp>
23 #include <boost/thread/recursive_mutex.hpp>
71 typedef boost::recursive_mutex mutex_type;
72 typedef boost::unique_lock<mutex_type> lock_type;
74 mutex_type confProcessorMutex_;
76 boost::signals2::signal<void (int, const avro::GenericDatum &, bool)> deltaReceivers_;
77 boost::signals2::signal<void ()> onProcessedObservers_;
79 boost::shared_ptr<Schema> schema_;
void addOnProcessedObserver(IConfigurationProcessedObserver &observer)
void unsubscribeFromUpdates(IGenericDeltaReceiver &receiver)
void removeOnProcessedObserver(IConfigurationProcessedObserver &observer)
~ConfigurationProcessor()
void onSchemaUpdated(boost::shared_ptr< avro::ValidSchema > schema)
ConfigurationProcessor(boost::shared_ptr< avro::ValidSchema > schema)
void subscribeForUpdates(IGenericDeltaReceiver &receiver)
void processConfigurationData(const boost::uint8_t *data, size_t data_length, bool full_resync)