diff options
Diffstat (limited to 'raw-mqtt-consumer.cpp')
-rw-r--r-- | raw-mqtt-consumer.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/raw-mqtt-consumer.cpp b/raw-mqtt-consumer.cpp index 86815c6..04453e6 100644 --- a/raw-mqtt-consumer.cpp +++ b/raw-mqtt-consumer.cpp @@ -1,17 +1,15 @@ #include "cassandra_support.h" #include "mqtt_support.h" +#include "misc_support.h" #include <thread> -#include <boost/lexical_cast.hpp> -#include <boost/program_options.hpp> #include <trygvis/sensor.h> #include <trygvis/sensor/io.h> namespace raw_mqtt_consumer { -using namespace std; -using namespace std::chrono; using namespace trygvis::cassandra_support; using namespace trygvis::mqtt_support; +using namespace trygvis::misc_support; using namespace trygvis::sensor; using namespace trygvis::sensor::io; using namespace boost; @@ -99,7 +97,7 @@ cassandra_future2 *insert_into_raw(unique_ptr<cassandra_session> &session, const cout << "day=" << day << endl; auto now_ms = std::chrono::time_point_cast<std::chrono::milliseconds>(system_now); - long timestamp = now_ms.time_since_epoch().count(); + auto timestamp = now_ms.time_since_epoch().count(); q.bind(1, timestamp); cout << "timestamp=" << timestamp << endl; @@ -192,6 +190,7 @@ int main(int argc, const char **argv) { } catch (po::required_option &e) { cerr << "Missing required option: " << e.get_option_name() << endl; cerr << all << endl; + return EXIT_FAILURE; } catch (po::unknown_option &e) { cerr << e.what() << endl; return EXIT_FAILURE; |