Minors

robotics-4-all · Jan 19, 2025 · 19fb269 · 19fb269
1 parent 7b707ea
commit 19fb269
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/commlib/aggregation.py b/commlib/aggregation.py
@@ -22,7 +22,9 @@ def create_subscriptions(self):
         for topic in self.input_topics:
             if topic in self.data_processors:
                 _procs = self.data_processors[topic]
-            _clb = functools.partial(self.on_msg_internal, _procs)
+                _clb = functools.partial(self.on_msg_internal, _procs)
+            else:
+                _clb = self.on_msg_internal
             self.node.create_psubscriber(topic=topic, on_message=_clb)
 
     def create_publisher(self):

diff --git a/examples/topic_merge/topic_merge.py b/examples/topic_merge/topic_merge.py
@@ -14,7 +14,7 @@ def on_message(msg):
 
 if __name__ == "__main__":
     if len(sys.argv) < 2:
-        broker = "mqtt"
+        broker = "redis"
     else:
         broker = str(sys.argv[1])
     if broker == "redis":