Add native test for @HttpExchange

Closes spring-projectsgh-139

Author: sdeleuze

webclient/src/aotSmokeTest/java/com/example/webclient/WebClientApplicationAotTests.java

@@ -31,4 +31,12 @@ void httpsWorks(AssertableOutput output) {
 		});
 	}
 
+	@Test
+	void serviceWorks(AssertableOutput output) {
+		Awaitility.await().atMost(Duration.ofSeconds(30)).untilAsserted(() -> {
+			assertThat(output).hasSingleLineContaining(
+					"service: ExchangeDataDto{url='https://httpbin.org/anything', method='GET'}");
+		});
+	}
+
 }

webclient/src/main/java/com/example/webclient/CLR.java

@@ -14,14 +14,18 @@ class CLR implements CommandLineRunner {
 
 	private final Builder webClientBuilder;
 
-	CLR(WebClient.Builder webClientBuilder) {
+	private final DataService dataService;
+
+	CLR(WebClient.Builder webClientBuilder, DataService dataService) {
 		this.webClientBuilder = webClientBuilder;
+		this.dataService = dataService;
 	}
 
 	@Override
 	public void run(String... args) {
 		http();
 		https();
+		service();
 	}
 
 	private void http() {
@@ -50,4 +54,15 @@ private void https() {
 		}
 	}
 
+	private void service() {
+		try {
+			ExchangeDataDto dto = this.dataService.getData();
+			System.out.printf("service: %s%n", dto);
+		}
+		catch (Exception ex) {
+			System.out.println("service failed:");
+			ex.printStackTrace(System.out);
+		}
+	}
+
 }

webclient/src/main/java/com/example/webclient/DataService.java

@@ -0,0 +1,10 @@
+package com.example.webclient;
+
+import org.springframework.web.service.annotation.GetExchange;
+
+interface DataService {
+
+	@GetExchange("/anything")
+	ExchangeDataDto getData();
+
+}

webclient/src/main/java/com/example/webclient/ExchangeDataDto.java

@@ -0,0 +1,33 @@
+package com.example.webclient;
+
+public class ExchangeDataDto {
+
+	private String url;
+
+	private String method;
+
+	public ExchangeDataDto() {
+	}
+
+	public String getUrl() {
+		return url;
+	}
+
+	public void setUrl(String url) {
+		this.url = url;
+	}
+
+	public String getMethod() {
+		return method;
+	}
+
+	public void setMethod(String method) {
+		this.method = method;
+	}
+
+	@Override
+	public String toString() {
+		return "ExchangeDataDto{" + "url='" + url + '\'' + ", method='" + method + '\'' + '}';
+	}
+
+}

webclient/src/main/java/com/example/webclient/WebClientApplication.java

@@ -3,6 +3,10 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.WebApplicationType;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.web.reactive.function.client.WebClient;
+import org.springframework.web.reactive.function.client.support.WebClientAdapter;
+import org.springframework.web.service.invoker.HttpServiceProxyFactory;
 
 @SpringBootApplication
 public class WebClientApplication {
@@ -14,4 +18,12 @@ public static void main(String[] args) throws InterruptedException {
 		Thread.currentThread().join(); // To be able to measure memory consumption
 	}
 
+	@Bean
+	DataService dataService(WebClient.Builder webClientBuilder) {
+		WebClient webClient = webClientBuilder.baseUrl("https://httpbin.org/").build();
+		HttpServiceProxyFactory factory = HttpServiceProxyFactory.builder(WebClientAdapter.forClient(webClient))
+				.build();
+		return factory.createClient(DataService.class);
+	}
+
 }