CollectAgent: Add option for special benchmark mode which discards all messages

collectagent/collectagent.cpp

@@ -73,6 +73,13 @@
 #define __STDC_FORMAT_MACROS
 #include <inttypes.h>
 
+/**
+ * Uncomment and recompile to activate CollectAgent's special benchmark mode.
+ * In this mode, all received messages will be discarded and no data is stored
+ * in the storage backend.
+ */
+//#define BENCHMARK_MODE
+
 using namespace std;
 
 int keepRunning;
@@ -236,6 +243,8 @@ int mqttCallback(SimpleMQTTMessage *msg)
   if (msg->isPublish())
     pmsgCtr++;
 
+#ifndef BENCHMARK_MODE
+
   uint64_t len;
   /*
    * Decode the message and put into the database.
@@ -406,15 +415,12 @@ int mqttCallback(SimpleMQTTMessage *msg)
 	      readingCtr+= readings.size();
 
               //mySensorCache.dump();
+          } else {
+              LOG(error) << "Message with empty topic received";
           }
-#if 1
-          else {
-              cout << "Wrong topic format: " << msg->getTopic() << "\n";
-              return 1;
-          }
-#endif
       }
   }
+#endif
   return 0;
 }