o More explicit bind functions, it is useful because Cassandra is touchy with its types.

o Saving the topic and message id in the raw record table.
o Dropping the mosquittopp, it is not very useful.

1 files changed, 4 insertions, 4 deletions

diff --git a/sm-mqtt-consumer.cpp b/sm-mqtt-consumer.cpp
index 5a0a23e..778eddf 100644
--- a/sm-mqtt-consumer.cpp
+++ b/sm-mqtt-consumer.cpp
@@ -137,14 +137,14 @@ private:
 cassandra_future2* insert_into_sm_by_day(cassandra_session *session, device_measurement &&measurement) {
     cassandra_statement stmt("INSERT INTO sm_by_day(device, day, timestamp, sensors) VALUES (?, ?, ?, ?);", 4);
 
-    stmt.bind(0, measurement.device);
+    stmt.bind_string(0, measurement.device);
 
     std::time_t t = system_clock::to_time_t(measurement.timestamp);
     char day[100];
     std::strftime(day, sizeof(day), "%Y-%m-%d", std::localtime(&t));
-    stmt.bind(1, day);
+    stmt.bind_string(1, day);
 
-    stmt.bind(2, measurement.timestamp.time_since_epoch().count());
+    stmt.bind_int64(2, measurement.timestamp.time_since_epoch().count());
 
     cassandra_collection sensors(CASS_COLLECTION_TYPE_LIST, measurement.sensors.size());
     for_each(measurement.sensors.cbegin(), measurement.sensors.cend(), [&](auto sensor) {
@@ -154,7 +154,7 @@ cassandra_future2* insert_into_sm_by_day(cassandra_session *session, device_meas
         sensors.append(std::move(tuple));
     });
 
-    stmt.bind(3, sensors);
+    stmt.bind_collection(3, sensors);
 
     return session->execute2(std::move(stmt));
 }