diff --git a/socketio/zmq_manager.py b/socketio/zmq_manager.py
index f5e6361..12dfe89 100644
--- a/socketio/zmq_manager.py
+++ b/socketio/zmq_manager.py
@@ -104,6 +104,7 @@ class ZmqManager(PubSubManager):  # pragma: no cover
             if isinstance(message, str):
                 message = pickle.loads(message)
             if isinstance(message, dict) and \
+                    message['type'] == 'message' and \
                     message['channel'] == self.channel and \
                     'data' in message:
                 yield message['data']