test: run on unique port

bytebeamio · Oct 1, 2024 · 267ae8f · 267ae8f
1 parent 15ffccf
commit 267ae8f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/rumqttc/tests/reliability.rs b/rumqttc/tests/reliability.rs
@@ -591,7 +591,7 @@ async fn state_is_being_cleaned_properly_and_pending_request_calculated_properly
 
 #[tokio::test]
 async fn resolve_on_qos0_before_write_to_tcp_buffer() {
-    let options = MqttOptions::new("dummy", "127.0.0.1", 3004);
+    let options = MqttOptions::new("dummy", "127.0.0.1", 3005);
     let (client, mut eventloop) = AsyncClient::new(options, 5);
 
     task::spawn(async move {
@@ -645,7 +645,7 @@ async fn resolve_on_qos0_before_write_to_tcp_buffer() {
 
 #[tokio::test]
 async fn resolve_on_qos1_ack_from_broker() {
-    let options = MqttOptions::new("dummy", "127.0.0.1", 3004);
+    let options = MqttOptions::new("dummy", "127.0.0.1", 3006);
     let (client, mut eventloop) = AsyncClient::new(options, 5);
 
     task::spawn(async move {
@@ -710,7 +710,7 @@ async fn resolve_on_qos1_ack_from_broker() {
 
 #[tokio::test]
 async fn resolve_on_qos2_ack_from_broker() {
-    let options = MqttOptions::new("dummy", "127.0.0.1", 3004);
+    let options = MqttOptions::new("dummy", "127.0.0.1", 3007);
     let (client, mut eventloop) = AsyncClient::new(options, 5);
 
     task::spawn(async move {