--- a/src/MQTTCommand.cpp	Fri May 06 21:54:09 2022 +0200
+++ b/src/MQTTCommand.cpp	Fri May 06 23:09:56 2022 +0200
@@ -24,6 +24,8 @@
 #include <sstream>
 #include <iomanip>
 
+#include <mosquittopp.h>
+
 #include <relpipe/writer/RelationalWriter.h>
 #include <relpipe/writer/RelpipeWriterException.h>
 #include <relpipe/writer/AttributeMetadata.h>
@@ -33,7 +35,6 @@
 #include <relpipe/cli/CLI.h>
 
 #include "MQTTCommand.h"
-#include "MQTT.h"
 #include "Hex.h"
 
 using namespace std;
@@ -47,7 +48,12 @@
 void MQTTCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) {
 	vector<AttributeMetadata> metadata;
 
-	std::shared_ptr<MQTT> mq(MQTT::open(convertor.to_bytes(configuration.queue), configuration.unlinkOnClose));
+	{
+		// TODO: remove
+		int major, minor, patch;
+		mosqpp::lib_version(&major, &minor, &patch);
+		std::cerr << "mosquitto version: " << major << "." << minor << "." << patch << std::endl;
+	}
 
 	writer->startRelation(configuration.relation,{
 		{L"queue", TypeId::STRING},
@@ -57,7 +63,7 @@
 
 	for (int i = configuration.messageCount; continueProcessing && i > 0; i--) {
 		// TODO: maybe rather call mq_timedreceive() inside and check continueProcessing (to be able to stop even when no messages are comming)
-		std::string message = mq->receive();
+		std::string message = "TODO"; // FIXME: receive message
 
 		writer->writeAttribute(configuration.queue);
 		writer->writeAttribute(Hex::toTxt(message));