SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Uses property based routing client request metadata

Browse Source
This commit is contained in:
spencergibb
2020-08-25 12:14:01 -04:00
parent d02b6998c3
commit 306dff3d0f
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-function-rsocket/src/test/java/org/springframework/cloud/function/rsocket/RoutingBrokerTests.java
View File

@@ -79,6 +79,7 @@ public class RoutingBrokerTests {
"--spring.cloud.function.rsocket.enabled=false", "--spring.cloud.function.rsocket.enabled=false",
"--io.rsocket.routing.client.enabled=true", "--io.rsocket.routing.client.enabled=true",
"--io.rsocket.routing.client.service-name=testclient", "--io.rsocket.routing.client.service-name=testclient",
"--io.rsocket.routing.client.address.toupper.service_name=samplefn",
"--io.rsocket.routing.client.brokers[0].host=localhost", "--io.rsocket.routing.client.brokers[0].host=localhost",
"--io.rsocket.routing.client.brokers[0].port=" + routingBrokerProxyPort, "--io.rsocket.routing.client.brokers[0].port=" + routingBrokerProxyPort,
"--io.rsocket.routing.broker.enabled=false"); "--io.rsocket.routing.broker.enabled=false");
@@ -87,7 +88,7 @@ public class RoutingBrokerTests {
SpringRouting routing = clientContext.getBean(SpringRouting.class); SpringRouting routing = clientContext.getBean(SpringRouting.class);
Mono<String> result = requester.route("toupper") // used to find a messagemapping, so unused here Mono<String> result = requester.route("toupper") // used to find a messagemapping, so unused here
// auto creates metadata // auto creates metadata
.metadata(routing.address("samplefn")) //.metadata(routing.address("samplefn"))
.data("\"hello\"") .data("\"hello\"")
.retrieveMono(String.class); .retrieveMono(String.class);