diff --git a/resolvers/listener.py b/resolvers/listener.py
index 753499d..9931608 100644
--- a/resolvers/listener.py
+++ b/resolvers/listener.py
@@ -24,4 +24,7 @@ async def reactions_worker():
             msg_data = message.get("data")
             if msg_data:
                 msg = json.loads(msg_data)
-                await handle_reaction(msg)
+                if msg.entity == "reaction":
+                    await handle_reaction(msg)
+                else:
+                    print(f"[resolvers.listener] unhandled msg: {msg}")