From f0ad6bf8acbabe92bdee493a830b1d3cad6ad1f3 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Mon, 31 Aug 2020 19:14:58 -0400 Subject: [PATCH] Updates to new routing client broker tcp properties --- .../cloud/function/rsocket/RoutingBrokerTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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"); }