diff --git a/src/communication.jl b/src/communication.jl
index 62b672e..91af37c 100644
--- a/src/communication.jl
+++ b/src/communication.jl
@@ -186,11 +186,14 @@ function mqttClientInstance_v2(
   if clearOldMsg
     chnames = keys(msgReceiveChannel)
     for i in chnames
-      while isready(msgReceiveChannel[i])
-        _ = take!(msgReceiveChannel[i])
+      totalmsg = msgReceiveChannel[i].n_avail_items #[TESTING]
+      if totalmsg > 0
+        while isready(msgReceiveChannel[i])
+          _ = take!(msgReceiveChannel[i])
+        end
+        println("Total $totalmsg old MQTT messages cleared", @__FILE__, ":", @__LINE__, " $(Dates.now())")
       end
     end
-    println("Old MQTT messages cleared")
   end
 
   return instance