17 #ifndef DEFAULTDELTAMANAGER_HPP_
18 #define DEFAULTDELTAMANAGER_HPP_
22 #include <boost/thread/mutex.hpp>
45 virtual void onDeltaRecevied(
int index,
const avro::GenericDatum &data,
bool full_resync);
69 boost::mutex subscriptionMutex_;
70 std::map<DeltaHandlerId, IDeltaReceiver*> subscriptionStorage_;
virtual void onDeltaRecevied(int index, const avro::GenericDatum &data, bool full_resync)
virtual void unsubscribeFromDeltaUpdates(const DeltaHandlerId &handlerId)
virtual void registerRootReceiver(IDeltaReceiver *rootReceiver)
virtual void subscribeForDeltaUpdates(const DeltaHandlerId &handlerId, IDeltaReceiver *receiver)