diff --git a/aprsd/client/aprsis.py b/aprsd/client/aprsis.py
index 2079be0..402685a 100644
--- a/aprsd/client/aprsis.py
+++ b/aprsd/client/aprsis.py
@@ -126,7 +126,10 @@ class APRSISClient(base.APRSClient):
         return aprs_client
 
     def consumer(self, callback, blocking=False, immortal=False, raw=False):
-        self._client.consumer(
-            callback, blocking=blocking,
-            immortal=immortal, raw=raw,
-        )
+        try:
+            self._client.consumer(
+                callback, blocking=blocking,
+                immortal=immortal, raw=raw,
+            )
+        except Exception as e:
+            LOG.error(f"Exception in consumer: {e}")