From 87f71a55e5d3697ac390a7f616a2ff91361ad5df Mon Sep 17 00:00:00 2001 From: spencergibb Date: Tue, 25 Aug 2020 14:17:36 -0400 Subject: [PATCH] Uses renamed RoutingMetadata --- .../cloud/function/rsocket/RoutingBrokerTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 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 e06fefa33..2bc9ef5b1 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 @@ -19,7 +19,7 @@ package org.springframework.cloud.function.rsocket; import java.util.function.Consumer; 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 reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -85,10 +85,10 @@ public class RoutingBrokerTests { "--io.rsocket.routing.broker.enabled=false"); RSocketRequester requester = clientContext.getBean(RSocketRequester.class); - //SpringRouting routing = clientContext.getBean(SpringRouting.class); + //RoutingMetadata metadata = clientContext.getBean(RoutingMetadata.class); Mono result = requester.route("toupper") // used to find a messagemapping, so unused here // auto creates metadata - //.metadata(routing.address("samplefn")) + //.metadata(metadata.address("samplefn")) .data("\"hello\"") .retrieveMono(String.class);