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

Uses renamed RoutingMetadata

Browse Source
This commit is contained in:
spencergibb
2020-08-25 14:17:36 -04:00
parent eb405e0af5
commit 87f71a55e5
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -19,7 +19,7 @@ package org.springframework.cloud.function.rsocket;
import java.util.function.Consumer; import java.util.function.Consumer;
import java.util.function.Function; import java.util.function.Function;
import io.rsocket.routing.client.spring.SpringRouting; import io.rsocket.routing.client.spring.RoutingMetadata;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
@@ -85,10 +85,10 @@ public class RoutingBrokerTests {
"--io.rsocket.routing.broker.enabled=false"); "--io.rsocket.routing.broker.enabled=false");
RSocketRequester requester = clientContext.getBean(RSocketRequester.class); RSocketRequester requester = clientContext.getBean(RSocketRequester.class);
//SpringRouting routing = clientContext.getBean(SpringRouting.class); //RoutingMetadata metadata = clientContext.getBean(RoutingMetadata.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(metadata.address("samplefn"))
.data("\"hello\"") .data("\"hello\"")
.retrieveMono(String.class); .retrieveMono(String.class);