Python: gave MQTT backend time to publish final (atexit) retractions

ipaacalib/python/src/ipaaca/backend_mqtt.py

@@ -108,6 +108,8 @@ else:
             #self._mqtt_client.on_publish = self.mqtt_callback_on_publish
             self.run_in_background()
         def deactivate(self):
+            pass
+        def deactivate_internal(self):
             self._mqtt_client.disconnect()
             self._mqtt_client = None
         def run_in_background(self):
@@ -130,6 +132,7 @@ else:
         def mqtt_callback_on_message(self, client, userdata, message):
             pass
         def publishData(self, data):
+            print('Informer publishing '+str(data.__class__.__name__)+' on '+self._scope)
             self._mqtt_client.publish(self._scope, ipaaca.converter.serialize(data), qos=2)
 
     class BackgroundEventDispatcher(threading.Thread):
@@ -166,6 +169,8 @@ else:
             #self._mqtt_client.on_publish = self.mqtt_callback_on_publish
             self.run_in_background()
         def deactivate(self):
+            pass
+        def deactivate_internal(self):
             self._mqtt_client.disconnect()
             self._mqtt_client = None
         def run_in_background(self):
@@ -191,6 +196,7 @@ else:
             LOGGER.warning('MQTT disconnect for '+str(self._scope)+' with result code '+str(rc))
         def mqtt_callback_on_message(self, client, userdata, message):
             event = EventWrapper(ipaaca.converter.deserialize(message.payload))
+            print('Received: '+str(event.data.__class__.__name__))
             dispatcher = BackgroundEventDispatcher(event, self._handlers)
             dispatcher.start()
         def addHandler(self, handler):
@@ -224,6 +230,8 @@ else:
             #self._mqtt_client.on_publish = self.mqtt_callback_on_publish
             self.run_in_background()
         def deactivate(self):
+            pass
+        def deactivate_internal(self):
             self._mqtt_client.disconnect()
             self._mqtt_client = None
         def run_in_background(self):
@@ -310,6 +318,8 @@ else:
             #self._mqtt_client.on_publish = self.mqtt_callback_on_publish
             self.run_in_background()
         def deactivate(self):
+            pass
+        def deactivate_internal(self):
             self._mqtt_client.disconnect()
             self._mqtt_client = None
         def run_in_background(self):
@@ -385,6 +395,7 @@ else:
             # back-end initialization code
             self._config = ipaaca.config.get_global_config()
             self._name = name
+            self._participants = set()
 
         def _get_name(self):
             return self._name
@@ -393,6 +404,8 @@ else:
         def teardown(self):
             LOGGER.info('MQTT teardown: waiting 1 sec for final deliveries')
             time.sleep(1)
+            for p in self._participants:
+                p.deactivate_internal()
 
         def Scope(self, scope_str):
             '''Scope adapter (glue replacing rsb.Scope)'''
@@ -401,24 +414,28 @@ else:
         def createLocalServer(self, buffer_impl, scope, config=None):
             LOGGER.debug('Creating a LocalServer on '+str(scope))
             s = LocalServer(buffer_impl, scope, self._config if config is None else config)
+            self._participants.add(s)
             s._live_event.wait(30.0)
             return s
          
         def createRemoteServer(self, scope, config=None):
             LOGGER.debug('Creating a RemoteServer on '+str(scope))
             s = RemoteServer(scope, self._config if config is None else config)
+            self._participants.add(s)
             s._live_event.wait(30.0)
             return s
 
         def createInformer(self, scope, config=None, dataType="ignored in this backend"):
             LOGGER.debug('Creating an Informer on '+str(scope))
             s = Informer(scope, self._config if config is None else config)
+            self._participants.add(s)
             s._live_event.wait(30.0)
             return s
 
         def createListener(self, scope, config=None):
             LOGGER.debug('Creating a Listener on '+str(scope))
             s = Listener(scope, self._config if config is None else config)
+            self._participants.add(s)
             s._live_event.wait(30.0)
             return s