Minor changes

src/MqttStreaming.h

@@ -38,6 +38,7 @@
   4.  Simple _FMT mechanism ala printf, but without the typeunsafetyness 
       and no internal buffers for replaceable stream printing
 */
+#pragma once
 
 #ifndef ARDUINO_STREAMING
 #define ARDUINO_STREAMING

src/TinyMqtt.cpp

@@ -84,7 +84,7 @@ void MqttClient::connect(MqttBroker* parentBroker)
 
 void MqttClient::connect(std::string broker, uint16_t port, uint16_t ka)
 {
-	debug("cnx: closing");
+	debug("MqttClient::connect");
 	keep_alive = ka;
 	close();
 	if (client) delete client;

src/TinyMqtt.h

@@ -235,7 +235,7 @@ class MqttClient
 		MqttError publishIfSubscribed(const Topic& topic, MqttMessage& msg);
 
 		void clientAlive(uint32_t more_seconds);
-		void processMessage(MqttMessage* message);
+		void processMessage(const MqttMessage* message);
 
 		bool mqtt_connected = false;
 		char mqtt_flags;