C++: provided additional event dispatcher (threaded as in Python)

ipaacalib/cpp/include/ipaaca/ipaaca-backend.h

@@ -184,6 +184,7 @@ class Listener {
         IPAACA_HEADER_EXPORT inline virtual ~Listener() { }
         //inline Listener(const Scope& scope, InputBuffer* buffer_ptr, Config::ptr config = nullptr)) {}
         void relay_received_event_to_buffer(Event::ptr event);
+        void relay_received_event_to_buffer_threaded(Event::ptr event);
 };
 
 class LocalServer {

ipaacalib/cpp/src/ipaaca-backend-mqtt.cc

@@ -263,7 +263,7 @@ IPAACA_EXPORT void MQTTListener::on_message(const struct mosquitto_message * mes
     auto event = ipaaca::converters::internal_deserialize(std::string((const char*) message->payload, message->payloadlen));
     //std::cout << "GOT AN EVENT of type " << event->getType() << std::endl;
     // let the Listener base class handle the propagation into a Buffer:
-    Listener::relay_received_event_to_buffer(event);
+    Listener::relay_received_event_to_buffer_threaded(event);
 }
 //}}}
 

ipaacalib/cpp/src/ipaaca-backend.cc

@@ -179,6 +179,15 @@ IPAACA_EXPORT void Listener::relay_received_event_to_buffer(Event::ptr event)
     //std::cout << "Will relay it" << std::endl;
     _buffer->_handle_iu_events(event);
 }
+IPAACA_EXPORT void Listener::relay_received_event_to_buffer_threaded(Event::ptr event)
+{
+    auto buffer = _buffer; // avoid a 'this' lambda capture
+    std::thread dispatcher(
+            [buffer,event] () {
+                    buffer->_handle_iu_events(event);
+            });
+    dispatcher.detach();
+}
 
 
 } // of namespace backend

ipaacalib/cpp/src/ipaaca-tester.cc

@@ -90,7 +90,17 @@ class TesterCpp {
 		std::cout << "}" << std::endl;
                 if (etype == IU_ADDED) {
                     std::cout << "Will send a modification to a received new IU" << std::endl;
-                    iu->payload()["seen_by_cpp"] = true;
+                    int cnt=5;
+                    while(cnt>0) {
+                        try {
+                            iu->payload()["seen_by_cpp"] = true;
+                            cnt = 0;
+                        } catch(...) {
+                            std::cout << "... failed, but we try more than once ..." << std::endl;
+                            cnt--;
+                            usleep(20000);
+                        }
+                    }
                 }
 	}