chore: testing

Author: BFergerson

build.gradle.kts

@@ -16,6 +16,7 @@ repositories {
 dependencies {
     implementation("io.dropwizard.metrics:metrics-core:4.2.19")
     implementation("io.micronaut:micronaut-management:3.9.4")
+    implementation("io.projectreactor:reactor-core:3.4.16")
 
     //attaches Source++ probe to the application
     javaagent("plus.sourceplus.probe:probe-jvm:0.7.9-SNAPSHOT")

src/main/java/spp/demo/command/ViewTraces.java

@@ -4,8 +4,11 @@
 import io.micronaut.http.annotation.Controller;
 import io.micronaut.http.annotation.Get;
 import io.micronaut.http.client.HttpClient;
+import io.micronaut.http.client.annotation.Client;
+import org.reactivestreams.Publisher;
+import reactor.core.publisher.Mono;
 
-import java.net.URL;
+import static io.micronaut.http.HttpRequest.GET;
 
 /**
  * This class is used to demonstrate the `View Traces` command.
@@ -21,22 +24,24 @@
 @Controller("/command")
 public class ViewTraces {
 
+    private final HttpClient httpClient;
+
+    public ViewTraces(@Client("/") HttpClient httpClient) {
+        this.httpClient = httpClient;
+    }
+
     /**
      * Execute the `View Traces` command with your caret anywhere between lines 31 and 38 to see the traces for
      * the endpoint below. Executing this command will open a list of traces for the given endpoint. Clicking on a
      * trace will open the trace details.
      */
     @Get("/view-traces")
-    public HttpResponse<Void> entryEndpoint() throws Exception {
-        try (HttpClient client = HttpClient.create(new URL("http://localhost:8080"))) {
-            return client.toBlocking().exchange("/command/view-traces/exit");
-        } catch (Exception e) {
-            return HttpResponse.serverError();
-        }
+    public Publisher<String> entryEndpoint() {
+        return Mono.from(httpClient.retrieve(GET("/command/view-traces/exit")));
     }
 
     @Get("/view-traces/exit")
-    public HttpResponse<Void> exitEndpoint() {
-        return HttpResponse.ok();
+    public HttpResponse<String> exitEndpoint() {
+        return HttpResponse.ok("Success");
     }
 }