open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve Vertx test stability 

By actiually waiting for test server to start listening.
This commit is contained in:
Nikolay Martynov 2019-01-11 08:59:05 -05:00
parent 5f1de1437f
commit 1b1f620318
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dd-java-agent/instrumentation/vertx/src/test/java/VertxWebTestServer.java
View File

@ -1,5 +1,6 @@
import datadog.trace.api.Trace; import datadog.trace.api.Trace;
import io.vertx.core.AbstractVerticle; import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
import io.vertx.core.Vertx; import io.vertx.core.Vertx;
import io.vertx.core.VertxOptions; import io.vertx.core.VertxOptions;
import io.vertx.ext.web.Router; import io.vertx.ext.web.Router;
@ -35,7 +36,7 @@ public class VertxWebTestServer extends AbstractVerticle {
} }
@Override @Override
public void start() { public void start(final Future<Void> startFuture) {
final Router router = Router.router(vertx); final Router router = Router.router(vertx);
router router
@ -66,7 +67,10 @@ public class VertxWebTestServer extends AbstractVerticle {
routingContext.response().putHeader("content-type", "text/html").end("Hello World"); routingContext.response().putHeader("content-type", "text/html").end("Hello World");
}); });
vertx.createHttpServer().requestHandler(router::accept).listen(port); vertx
.createHttpServer()
.requestHandler(router::accept)
.listen(port, h -> startFuture.complete());
} }
@Trace @Trace