Remove Echo messages as those are overriding processing

kayleg · Mar 17, 2023 · 6e9aef8 · 6e9aef8
1 parent c2c44e7
commit 6e9aef8
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/src/subscription.rs b/src/subscription.rs
@@ -101,11 +101,6 @@ impl Subscription {
                     log::debug!("{}", PING);
                     self.acknowledge_messages(vec![m.ack_id]).await;
                     continue;
-                } else {
-                    // Echo as info, in case we want to check the queue status
-                    log::info!("echo - {}", String::from_utf8_lossy(&data));
-                    self.acknowledge_messages(vec![m.ack_id]).await;
-                    continue;
                 }
             }
             batch.push((T::from(m.message), m.ack_id));