diff --git a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RoutingBrokerTests.java b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RoutingBrokerTests.java index 2d92678df..2eb9a1f96 100644 --- a/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RoutingBrokerTests.java +++ b/spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RoutingBrokerTests.java @@ -109,8 +109,8 @@ public class RoutingBrokerTests { .run("--logging.level.org.springframework.cloud.function=DEBUG", "--io.rsocket.routing.client.enabled=true", "--io.rsocket.routing.client.service-name=samplefn", - "--io.rsocket.routing.client.brokers[0].host=localhost", - "--io.rsocket.routing.client.brokers[0].port=" + routingBrokerProxyPort, + "--io.rsocket.routing.client.brokers[0].tcp.host=localhost", + "--io.rsocket.routing.client.brokers[0].tcp.port=" + routingBrokerProxyPort, "--io.rsocket.routing.broker.enabled=false", "--spring.cloud.function.definition=uppercase"); @@ -121,8 +121,8 @@ public class RoutingBrokerTests { "--io.rsocket.routing.client.enabled=true", "--io.rsocket.routing.client.service-name=testclient", routingWithProperty ? "--io.rsocket.routing.client.address.uppercase.service_name=samplefn" : "", - "--io.rsocket.routing.client.brokers[0].host=localhost", - "--io.rsocket.routing.client.brokers[0].port=" + routingBrokerProxyPort, + "--io.rsocket.routing.client.brokers[0].tcp.host=localhost", + "--io.rsocket.routing.client.brokers[0].tcp.port=" + routingBrokerProxyPort, "--io.rsocket.routing.broker.enabled=false"); }