diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2015-07-16 13:43:13 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2015-07-16 13:43:13 +0200 |
commit | b632036b153297f83b10f6d960ccfe0c1772f00e (patch) | |
tree | fd56c04b7b08da0be010a5ce72162a3a474adf29 /sm-mqtt-consumer.cpp | |
parent | d77ebb924c1eeca345bbb3f1eeb2df3058a52a18 (diff) | |
download | mqtt-cassandra-bridge-b632036b153297f83b10f6d960ccfe0c1772f00e.tar.gz mqtt-cassandra-bridge-b632036b153297f83b10f6d960ccfe0c1772f00e.tar.bz2 mqtt-cassandra-bridge-b632036b153297f83b10f6d960ccfe0c1772f00e.tar.xz mqtt-cassandra-bridge-b632036b153297f83b10f6d960ccfe0c1772f00e.zip |
o More Cassandra wrappers.
o Using more futures.
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) { |