o Adding a MQTT consumer that stores the parsed record in Cassandra.

1 files changed, 25 insertions, 0 deletions

diff --git a/mqtt_support.h b/mqtt_support.h
new file mode 100644
index 0000000..9a9f7fe
--- /dev/null
+++ b/mqtt_support.h
@@ -0,0 +1,25 @@
+#ifndef TRYGVIS_MQTT_SUPPORT_H
+#define TRYGVIS_MQTT_SUPPORT_H
+
+#include "mosquittopp.h"
+
+namespace trygvis {
+namespace mqtt_support {
+
+using namespace mosqpp;
+
+class mqtt_lib {
+public:
+    mqtt_lib() {
+        mosquitto_lib_init();
+    }
+
+    ~mqtt_lib() {
+        mosquitto_lib_cleanup();
+    }
+};
+
+}
+}
+
+#endif