Remove Echo messages as those are overriding processing

Carlos Cabanero · Carlos Cabanero · commit 6e9aef8cb94a · 2023-03-17T16:39:19.000Z
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));

Original file line number	Diff line number	Diff line change
`@@ -101,11 +101,6 @@ impl Subscription {`
`101`	`101`	`log::debug!("{}", PING);`
`102`	`102`	`self.acknowledge_messages(vec![m.ack_id]).await;`
`103`	`103`	`continue;`
`104`		`- } else {`
`105`		`- // Echo as info, in case we want to check the queue status`
`106`		`- log::info!("echo - {}", String::from_utf8_lossy(&data));`
`107`		`- self.acknowledge_messages(vec![m.ack_id]).await;`
`108`		`- continue;`
`109`	`104`	`}`
`110`	`105`	`}`
`111`	`106`	`batch.push((T::from(m.message), m.ack_id));`