Swallow message errors and continue.

dronekit · Mar 1, 2016 · 6c4fe4c · 6c4fe4c
1 parent e836c57
commit 6c4fe4c
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/dronekit/__init__.py b/dronekit/__init__.py
@@ -1464,9 +1464,21 @@ def remove_message_listener(self, name, fn):
 
     def notify_message_listeners(self, name, msg):
         for fn in self._message_listeners.get(name, []):
-            fn(self, name, msg)
+            try:
+                fn(self, name, msg)
+            except Exception as e:
+                errprinter('>>> Exception in message handler for %s' %
+                           msg.get_type())
+                errprinter('>>> ' + str(e))
+
         for fn in self._message_listeners.get('*', []):
-            fn(self, name, msg)
+            try:
+                fn(self, name, msg)
+            except Exception as e:
+                errprinter('>>> Exception in message handler for %s' %
+                           msg.get_type())
+                errprinter('>>> ' + str(e))
+
 
     def close(self):
         return self._handler.close()