diff --git a/rumqttc/tests/reliability.rs b/rumqttc/tests/reliability.rs
index 9933dfc1..83e50cbc 100644
--- 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 {