Add WebFlux routing instrumentation

Author: trask

agent/instrumentation/build.gradle

@@ -46,10 +46,12 @@ dependencies {
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-opentelemetry-api-0.2.0', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-opentelemetry-api-0.2.4', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-opentelemetry-api-0.3', version: instrumentationVersion
+    compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-reactor-3.1', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-request-2.3', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-request-3.0', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-spring-scheduling-3.1', version: instrumentationVersion
     compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-spring-webmvc-3.1', version: instrumentationVersion
+    compile group: 'io.opentelemetry.auto.instrumentation', name: 'instrumentation-spring-webflux-5.0', version: instrumentationVersion
 
     // also: jaxrs, spring, struts
 

settings.gradle

@@ -76,7 +76,7 @@ include ':test:smoke:testApps:HttpClients'
 include ':test:smoke:testApps:WebAuto'
 include ':test:smoke:testApps:SpringBoot1_3Auto'
 include ':test:smoke:testApps:SpringBootAuto'
-include ':test:smoke:testApps:Netty'
+include ':test:smoke:testApps:WebFlux'
 include ':test:smoke:testApps:JMS'
 include ':test:smoke:testApps:Kafka'
 include ':test:smoke:testApps:SpringCloudStream'

test/smoke/testApps/Netty/build.gradle renamed to test/smoke/testApps/WebFlux/build.gradle

@@ -16,7 +16,7 @@ public String root() {
         return "OK";
     }
 
-    @GetMapping("/test")
+    @GetMapping("/test/**")
     public Mono<String> test() {
         CompletableFuture<String> completableFuture = new CompletableFuture<>();
         Executors.newSingleThreadExecutor().execute(new Runnable() {

test/smoke/testApps/Netty/src/main/java/com/microsoft/ajl/simple/SpringBootApp.java renamed to test/smoke/testApps/WebFlux/src/main/java/com/microsoft/ajl/simple/SpringBootApp.java

@@ -10,25 +10,28 @@
 import static org.junit.Assert.*;
 
 @UseAgent
-public class NettyTest extends AiSmokeTest {
+public class WebFluxTest extends AiSmokeTest {
 
     @Test
     @TargetUri("/test")
     public void doMostBasicTest() throws Exception {
         List<Envelope> rdList = mockedIngestion.waitForItems("RequestData", 1);
+        assertEquals(0, mockedIngestion.getCountForType("RemoteDependencyData"));
 
         Envelope rdEnvelope = rdList.get(0);
 
         RequestData rd = (RequestData) ((Data) rdEnvelope.getData()).getBaseData();
 
         assertTrue(rd.getSuccess());
+        assertEquals("GET /test/**", rd.getName());
         assertEquals("200", rd.getResponseCode());
     }
 
     @Test
     @TargetUri("/exception")
     public void testException() throws Exception {
         List<Envelope> rdList = mockedIngestion.waitForItems("RequestData", 1);
+        assertEquals(0, mockedIngestion.getCountForType("RemoteDependencyData"));
 
         Envelope rdEnvelope = rdList.get(0);
 
@@ -42,6 +45,7 @@ public void testException() throws Exception {
     @TargetUri("/futureException")
     public void testFutureException() throws Exception {
         List<Envelope> rdList = mockedIngestion.waitForItems("RequestData", 1);
+        assertEquals(0, mockedIngestion.getCountForType("RemoteDependencyData"));
 
         Envelope rdEnvelope = rdList.get(0);