diff --git a/monitord/plugins/libmplugin_mqtt.cpp b/monitord/plugins/libmplugin_mqtt.cpp
index 8743fbf..49c247f 100644
--- a/monitord/plugins/libmplugin_mqtt.cpp
+++ b/monitord/plugins/libmplugin_mqtt.cpp
@@ -108,8 +108,8 @@
 	LOG_DEBUG(msg);
 
 	// transmit message
-	check(pMQTT->publish(NULL, topic.c_str(), msg.length(), msg.c_str()), "Could not publish", false);
-
+	//check(pMQTT->publish(NULL, topic.c_str(), msg.length(), msg.c_str()), "Could not publish", false);
+	pMQTT->send(topic, msg);
 
 	return true;
 }
@@ -168,7 +168,7 @@
 }
 
 
-void myMQTT::send(const std::string &topic, const std::string &message)
+void myMQTT::send(const std::string& topic, const std::string& message)
 {
 	publish(NULL, topic.c_str(), message.length(), message.c_str());
 }
@@ -176,19 +176,25 @@
 
 void myMQTT::on_connect(int rc)
 {
-	DD("on_connect");
+	LOG_INFO("on_connect");
 }
 
 
 void myMQTT::on_disconnect(int rc)
 {
-	DD("on_disconnect");
+	LOG_INFO("on_disconnect");
 }
 
 
 void myMQTT::on_message(const struct mosquitto_message *message)
 {
-	DD("on_message");
+	char payload[message->payloadlen];
+	memcpy(payload, message->payload, message->payloadlen);
+
+	std::string topic = message->topic;
+	std::string msg = payload;
+
+	LOG_DEBUG("Got message: " << topic << " - " << msg);
 }
 
 
@@ -197,4 +203,3 @@
 	DD("on_subcribe");
 }
 
-
diff --git a/monitord/plugins/libmplugin_mqtt.h b/monitord/plugins/libmplugin_mqtt.h
index 1bda825..6ed247c 100644
--- a/monitord/plugins/libmplugin_mqtt.h
+++ b/monitord/plugins/libmplugin_mqtt.h
@@ -21,7 +21,7 @@
 	explicit myMQTT();
 	~myMQTT();
 
-	void send(const std::string &topic, const std::string &message);
+	void send(const std::string& topic, const std::string& message);
 
 	void on_connect(int rc);
 	void on_disconnect(int rc);
@@ -45,7 +45,7 @@
 	virtual ~MonitorPlugInMQTT();
 
 	// virtual functions
-	virtual bool initProcessing(class MonitorConfiguration* configPtr,XMLNode config);
+	virtual bool initProcessing(class MonitorConfiguration* configPtr, XMLNode config);
 	virtual bool processResult(class ModuleResultBase *pRes);
 	virtual bool quitProcessing();
 	virtual void Show();