ch.Publish -> ch.PublishWithContext

rabbitmq · Jan 2, 2024 · 697ab71 · 697ab71
1 parent 6881ae1
commit 697ab71
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/system_tests/utils.go b/system_tests/utils.go
@@ -284,7 +284,8 @@ func publishToQueueAMQPS(message, username, password, hostname, amqpsPort, caFil
 		return err
 	}
 
-	err = ch.Publish(
+	err = ch.PublishWithContext(
+		context.TODO(),
 		"",     // exchange
 		q.Name, // routing key
 		false,  // mandatory