catch deconding exceptions

12urenloop · Nov 9, 2019 · 6ba792f · 6ba792f
1 parent 1e11dc6
commit 6ba792f
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/java/telraam/beacon/Beacon.java b/src/main/java/telraam/beacon/Beacon.java
@@ -97,7 +97,13 @@ public void run() {
                                     msgBuf.remove(msgBuf.size() - 1);
                                 }
 
-                                this.data(new BeaconMessage(msgBuf));
+                                // Catch errors thrown at message decoding and propagate
+                                try {
+                                    this.data(new BeaconMessage(msgBuf));
+                                } catch (Exception e) {
+                                    this.error(e);
+                                }
+
                                 readingMsg = false;
                             } else {
                                 this.error(new BeaconException.MsgEndWithNoStart());