aboutsummaryrefslogtreecommitdiff
path: root/raw-mqtt-consumer.cpp
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2015-08-04 22:09:04 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2015-08-04 22:09:04 +0200
commit6e43b92686a9d8bf476567113fbc21677338eb08 (patch)
tree0f9804022705b46f322e2d28cbbbc489b0853425 /raw-mqtt-consumer.cpp
parentcf94e623ff3c3dcdd4ca6a59632d48bd17b75d55 (diff)
downloadmqtt-cassandra-bridge-6e43b92686a9d8bf476567113fbc21677338eb08.tar.gz
mqtt-cassandra-bridge-6e43b92686a9d8bf476567113fbc21677338eb08.tar.bz2
mqtt-cassandra-bridge-6e43b92686a9d8bf476567113fbc21677338eb08.tar.xz
mqtt-cassandra-bridge-6e43b92686a9d8bf476567113fbc21677338eb08.zip
o Adding even better --help handling.
Fixing handling of timestamps on 32-bit platforms. Defining a timestamp_t type and useing it all over.
Diffstat (limited to 'raw-mqtt-consumer.cpp')
-rw-r--r--raw-mqtt-consumer.cpp9
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;