diff --git a/cpp/data/eigerfan/src/MultiPullBroker.cpp b/cpp/data/eigerfan/src/MultiPullBroker.cpp index 7fc54bf..29360ee 100644 --- a/cpp/data/eigerfan/src/MultiPullBroker.cpp +++ b/cpp/data/eigerfan/src/MultiPullBroker.cpp @@ -4,8 +4,11 @@ #include // getLogger +#include "EigerDefinitions.h" #include "MultiPullBroker.h" +using namespace Eiger; + MultiPullBroker::MultiPullBroker( std::string& sink_endpoint, int thread_count diff --git a/cpp/data/eigerfan/src/eigerfan_main.cpp b/cpp/data/eigerfan/src/eigerfan_main.cpp index 916b1af..f99ab57 100644 --- a/cpp/data/eigerfan/src/eigerfan_main.cpp +++ b/cpp/data/eigerfan/src/eigerfan_main.cpp @@ -15,7 +15,7 @@ #include #include #include -#include +#include #include #include @@ -263,7 +263,7 @@ int parse_arguments(int argc, char** argv, EigerFanConfig &cfg) if (vm.count("context-threads")) { - cfg.setNum0MQContexThreads(vm["context-threads"].as()); + cfg.setNum0MQContextThreads(vm["context-threads"].as()); LOG4CXX_DEBUG(logger, "Setting number of ZeroMQ context threads to " << cfg.getNum0MQContextThreads()); }