diff options
Diffstat (limited to 'sm-mqtt-consumer.cpp')
| -rw-r--r-- | sm-mqtt-consumer.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/sm-mqtt-consumer.cpp b/sm-mqtt-consumer.cpp index d7dbfdc..e1f6801 100644 --- a/sm-mqtt-consumer.cpp +++ b/sm-mqtt-consumer.cpp @@ -47,7 +47,7 @@ struct device_measurement { buf << "device=" << device; buf << ", timestamp=" << timestamp; std::for_each(sensors.begin(), sensors.end(), [&](auto &sensor) { - buf << ", #" << sensor.sensor << "=" + sensor.value; + buf << ", #" << sensor.sensor << "=" << sensor.value; }); return buf.str(); } @@ -158,7 +158,7 @@ auto insert_into_sm_by_day(CassSession *session, device_measurement &&measuremen q.bind(3, sensors); - return cass_session_execute(session, q.statement); + return cass_session_execute(session, q); } template<typename Target, typename Source> @@ -252,7 +252,7 @@ void on_message(const struct mosquitto_message *message) { cout << "Measurement: " << measurement.str() << endl; if (current_cassandra_session) { - handle_future(insert_into_sm_by_day(current_cassandra_session->session, std::move(measurement)), [&](auto future) { + handle_future(insert_into_sm_by_day((CassSession*) current_cassandra_session.get(), std::move(measurement)), [&](auto future) { cout << "Success!" << endl; }, [&](auto future, auto err) { cout << "Failure: " << error_message(future) << endl; @@ -263,9 +263,9 @@ void on_message(const struct mosquitto_message *message) { }); } -int main(int argc, const char **argv) { - mqtt_lib mqtt_lib(); +mqtt_lib mqtt_lib; +int main(int argc, const char **argv) { string cassandra_cluster; po::options_description all("Options"); all.add_options()("cassandra-cluster", po::value<string>(&cassandra_cluster)->default_value("127.0.0.1")); @@ -303,7 +303,7 @@ int main(int argc, const char **argv) { cass_cluster_set_contact_points(cluster, cassandra_cluster.c_str()); - connect_future = cass_session_connect(session->session, cluster); + connect_future = cass_session_connect((CassSession*) session.get(), cluster); if (cass_future_error_code(connect_future) != CASS_OK) { string s = to_string(connect_future); @@ -314,7 +314,7 @@ int main(int argc, const char **argv) { cout << "Connected to Cassandra" << endl; current_cassandra_session = std::move(session); - execute_query(current_cassandra_session->session, "USE " + keyspace_name); + execute_query((CassSession*) current_cassandra_session.get(), "USE " + keyspace_name); should_run = true; while (should_run) { |