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

Temporarily disable rsocket-routing-broker integration

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-09-23 16:24:01 +02:00
parent 1b6bfef3b9
commit c3d6b48e92
3 changed files with 34 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,8 +18,8 @@ package org.springframework.cloud.function.rsocket;
import java.util.function.Function;
import io.rsocket.routing.client.spring.RoutingMetadata;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
@@ -39,6 +39,7 @@ import org.springframework.util.SocketUtils;
* @author Oleg Zhurakousky
* @since 3.1
*/
@Disabled
public class RoutingBrokerTests {
ConfigurableApplicationContext functionContext;
@@ -77,19 +78,19 @@ public class RoutingBrokerTests {
@Test
public void testRoutingWithMessage() throws Exception {
this.setup(false);
RSocketRequester requester = clientContext.getBean(RSocketRequester.class);
RoutingMetadata metadata = clientContext.getBean(RoutingMetadata.class);
Mono<String> result = requester.route("uppercase") // used to find function
.metadata(metadata.address("samplefn"))
.data("\"hello\"")
.retrieveMono(String.class);
StepVerifier
.create(result)
.expectNext("HELLO")
.expectComplete()
.verify();
// this.setup(false);
// RSocketRequester requester = clientContext.getBean(RSocketRequester.class);
// RoutingMetadata metadata = clientContext.getBean(RoutingMetadata.class);
// Mono<String> result = requester.route("uppercase") // used to find function
// .metadata(metadata.address("samplefn"))
// .data("\"hello\"")
// .retrieveMono(String.class);
//
// StepVerifier
// .create(result)
// .expectNext("HELLO")
// .expectComplete()
// .verify();
}
private void setup(boolean routingWithProperty) {