From b41bc20702e888943ddbd2d5b87f429c118a30ec Mon Sep 17 00:00:00 2001
From: amigin <amigin@gmail.com>
Date: Mon, 5 Aug 2024 15:43:43 +0300
Subject: [PATCH] Added Debug Topic

---
 .../src/subscriber/messages_reader.rs               | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/my-service-bus-abstractions/src/subscriber/messages_reader.rs b/my-service-bus-abstractions/src/subscriber/messages_reader.rs
index 1fe7d57..6a302de 100644
--- a/my-service-bus-abstractions/src/subscriber/messages_reader.rs
+++ b/my-service-bus-abstractions/src/subscriber/messages_reader.rs
@@ -98,6 +98,19 @@ impl<TMessageModel: MySbMessageDeserializer<Item = TMessageModel>> Drop
     for MessagesReader<TMessageModel>
 {
     fn drop(&mut self) {
+        if let Ok(debug_topic) = std::env::var("DEBUG_TOPIC") {
+            if debug_topic == self.data.topic_id.as_str() {
+                println!(
+                    "Confirmation: Topic: {}, Queue:{}, Total Amount: {}, Delivered Amount: {},  Not Delivered amount: {}",
+                    self.data.topic_id.as_str(),
+                    self.data.queue_id.as_str(),
+                    self.total_messages_amount,
+                    self.delivered.queue_size(),
+                    self.not_delivered.queue_size()
+                );
+            }
+        };
+
         if self.delivered.queue_size() == self.total_messages_amount {
             self.data.client.confirm_delivery(
                 self.data.topic_id.as_str(),