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> Drop for MessagesReader { 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(),