merging

Author: DanielePalaia

tests/integration/consumer_test.rs

@@ -93,29 +93,15 @@ async fn super_stream_consumer_test() {
     for n in 0..message_count {
         let msg = Message::builder().body(format!("message{}", n)).build();
         let _ = super_stream_producer
-            .send(msg, |confirmation_status| async move {
-                println!("Message confirmed with status {:?}", confirmation_status);
-            })
+            .send(msg, |confirmation_status| async move {})
             .await
             .unwrap();
     }
 
     let mut received_messages = 0;
     let handle = super_stream_consumer.handle();
 
-    println!("before looping");
-    while let delivery = super_stream_consumer.next().await.unwrap() {
-        println!("inside while delivery loop");
-        let d = delivery.unwrap();
-        println!(
-            "Got message: {:#?} from stream: {} with offset: {}",
-            d.message()
-                .data()
-                .map(|data| String::from_utf8(data.to_vec()).unwrap()),
-            d.stream(),
-            d.offset()
-        );
-
+    while let _ = super_stream_consumer.next().await.unwrap() {
         received_messages = received_messages + 1;
         if received_messages == 10 {
             break;

tests/integration/producer_test.rs

@@ -13,8 +13,7 @@ use rabbitmq_stream_client::{
 use crate::common::{Countdown, TestEnvironment};
 
 use rabbitmq_stream_client::types::{
-    HashRoutingMurmurStrategy, RoutingKeyRoutingStrategy,
-    RoutingStrategy,
+    HashRoutingMurmurStrategy, RoutingKeyRoutingStrategy, RoutingStrategy,
 };
 
 use std::sync::atomic::{AtomicU32, Ordering};