diff --git a/socketio/zmq_manager.py b/socketio/zmq_manager.py
index 12dfe89..2ad79ce 100644
--- a/socketio/zmq_manager.py
+++ b/socketio/zmq_manager.py
@@ -102,7 +102,10 @@ class ZmqManager(PubSubManager):  # pragma: no cover
     def _listen(self):
         for message in self.zmq_listen():
             if isinstance(message, str):
-                message = pickle.loads(message)
+                try:
+                    message = pickle.loads(message)
+                except Exception:
+                    pass
             if isinstance(message, dict) and \
                     message['type'] == 'message' and \
                     message['channel'] == self.channel and \