15 #include <boost/thread.hpp>
16 #include <boost/bind.hpp>
17 #include <boost/archive/binary_oarchive.hpp>
19 #include "baseMQtools.h"
33 for (
auto itr : dataToProcess){
34 LOG(INFO) <<
"Data in Burst: " << itr.first;
39 LOG(INFO) <<
"Finished!";
virtual void ProcessData(std::map< std::string, BurstData > &dataToProcess)