Merge pull request #75 from chainbound/chore/add-trace

chainbound · Mar 7, 2024 · ed424a0 · ed424a0
2 parents 603f29d + a68270a
commit ed424a0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/msg-socket/src/pub/session.rs b/msg-socket/src/pub/session.rs
@@ -48,6 +48,11 @@ impl<Io: AsyncRead + AsyncWrite + Unpin> SubscriberSession<Io> {
             // Generate the wire message and increment the sequence number
             self.pending_egress = Some(msg.into_wire(self.seq));
             self.seq = self.seq.wrapping_add(1);
+        } else {
+            trace!(
+                topic = msg.topic(),
+                "Message does not match topic filter, discarding"
+            );
         }
     }