fixing last merging issues

Author: DanielePalaia

tests/integration/producer_test.rs

@@ -10,9 +10,10 @@ use rabbitmq_stream_client::types::{
     RoutingStrategy, SimpleValue,
 };
 
-use crate::common::TestEnvironment;
+use rabbitmq_stream_client::Environment;
+
+use crate::common::{Countdown, TestEnvironment};
 use std::sync::atomic::{AtomicU32, Ordering};
-use std::sync::Arc;
 use tokio::sync::Notify;
 
 #[tokio::test(flavor = "multi_thread")]