From 24a1b22dfd45b5bfc2da2fdd897e26f5fbc85072 Mon Sep 17 00:00:00 2001 From: Paolo Patruno Date: Wed, 22 May 2024 15:58:57 +0200 Subject: [PATCH] release 16.6 --- python/rmap/__init__.py | 2 +- python/rmap/report2observation.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/python/rmap/__init__.py b/python/rmap/__init__.py index 46b756129..555791dc5 100644 --- a/python/rmap/__init__.py +++ b/python/rmap/__init__.py @@ -1 +1 @@ -__version__ = "16.5" +__version__ = "16.6" diff --git a/python/rmap/report2observation.py b/python/rmap/report2observation.py index 3e82346fd..e18f3affd 100644 --- a/python/rmap/report2observation.py +++ b/python/rmap/report2observation.py @@ -36,7 +36,7 @@ def __init__(self,mqtt_host,mqttuser, mqttpassword, subtopics, topicmaint, termi self.mqtt_host=mqtt_host self.subtopics=subtopics self.client_id = "report2observation" - self.mqttc = paho.Client(self.client_id, clean_session=False) + self.mqttc = paho.Client(self.client_id, clean_session=False) # with qos 1 self.terminateevent=terminate self.mqttuser=mqttuser self.mqttpassword=mqttpassword @@ -77,7 +77,7 @@ def on_connect(self,mosq, userdata, flags, rc): for topic in self.subtopics: logging.debug("Subscribing to topic %s" % topic) - self.mqttc.subscribe(topic, 0) + self.mqttc.subscribe(topic, 1) # qos 1 def on_publish(self,mosq, userdata, mid): logging.debug("pubblish %s with id %s" % (userdata, mid))