17 #ifndef SCHEMAPERSISTENCEMANAGER_HPP_
18 #define SCHEMAPERSISTENCEMANAGER_HPP_
22 #include <boost/thread/mutex.hpp>
41 , ignoreSchemaUpdate_(false)
62 typedef boost::mutex mutex_type;
63 typedef boost::unique_lock<mutex_type> lock_type;
65 void readStoredSchema();
67 mutex_type schemaGuard_;
68 mutex_type schemaPersistenceGuard_;
72 bool ignoreSchemaUpdate_;
SchemaPersistenceManager()
void onSchemaUpdated(boost::shared_ptr< avro::ValidSchema > schema)
void setSchemaProcessor(ISchemaProcessor *processor)
void setSchemaStorage(ISchemaStorage *storage)