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, 11 insertions, 6 deletions

diff --git a/cassandra_support.h b/cassandra_support.h
index 3f49be2..2e3ea19 100644
--- a/cassandra_support.h
+++ b/cassandra_support.h
@@ -395,32 +395,37 @@ public:
 
     cassandra_statement &operator=(const cassandra_statement &) = delete;
 
-    void bind(size_t i, const string &value) {
+    void bind_string(size_t i, const string &value) {
         auto err = cass_statement_bind_string(statement, i, value.c_str());
         assert_ok("cass_statement_bind_string", err);
     }
 
-    void bind(size_t i, const char *value) {
+    void bind_string(size_t i, const char *value) {
         auto err = cass_statement_bind_string(statement, i, value);
         assert_ok("cass_statement_bind_string", err);
     }
 
-    void bind(size_t i, const cass_int64_t value) {
+    void bind_int32(size_t i, const cass_int32_t value) {
+        auto err = cass_statement_bind_int32(statement, i, value);
+        assert_ok("cass_statement_bind_int32", err);
+    }
+
+    void bind_int64(size_t i, const cass_int64_t value) {
         auto err = cass_statement_bind_int64(statement, i, value);
         assert_ok("cass_statement_bind_int64", err);
     }
 
-    void bind(size_t i, const CassCollection *value) {
+    void bind_collection(size_t i, const CassCollection *value) {
         auto err = cass_statement_bind_collection(statement, i, value);
         assert_ok("cass_statement_bind_collection", err);
     }
 
-    void bind(size_t i, const cassandra_collection &value) {
+    void bind_collection(size_t i, const cassandra_collection &value) {
         auto err = cass_statement_bind_collection(statement, i, value);
         assert_ok("cass_statement_bind_collection", err);
     }
 
-    void bind(size_t i, const std::vector<string> &&values) {
+    void bind_list(size_t i, const std::vector<string> &&values) {
         cassandra_collection c(CassCollectionType::CASS_COLLECTION_TYPE_LIST, values.size());
 
         for (const auto &value : values) {