@@ -48,18 +48,17 @@ public abstract class TracingTestBase {
4848
4949 @ Before
5050 public void setup () throws Exception {
51- vertx = Vertx .vertx (new VertxOptions ().setTracingOptions (
52- new TracingOptions ().setFactory (tracingOptions -> new VertxTracer () {
53- @ Override
54- public Object sendRequest (Context context , SpanKind kind , TracingPolicy tracingPolicy , Object request , String operation , BiConsumer headers , TagExtractor tagExtractor ) {
55- return tracer .sendRequest (context , kind , tracingPolicy , request , operation , headers , tagExtractor );
56- }
57- @ Override
58- public void receiveResponse (Context context , Object response , Object payload , Throwable failure , TagExtractor tagExtractor ) {
59- tracer .receiveResponse (context , response , payload , failure , tagExtractor );
60- }
61- }))
62- );
51+ vertx = Vertx .builder ()
52+ .withTracer (tracingOptions -> new VertxTracer () {
53+ @ Override
54+ public Object sendRequest (Context context , SpanKind kind , TracingPolicy tracingPolicy , Object request , String operation , BiConsumer headers , TagExtractor tagExtractor ) {
55+ return tracer .sendRequest (context , kind , tracingPolicy , request , operation , headers , tagExtractor );
56+ }
57+ @ Override
58+ public void receiveResponse (Context context , Object response , Object payload , Throwable failure , TagExtractor tagExtractor ) {
59+ tracer .receiveResponse (context , response , payload , failure , tagExtractor );
60+ }
61+ }).build ();
6362 pool = createPool (vertx );
6463 }
6564
0 commit comments