diff --git a/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboTelemetry.java b/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboTelemetry.java index a44489af3463..5319f496b4a6 100644 --- a/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboTelemetry.java +++ b/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboTelemetry.java @@ -35,23 +35,13 @@ public static DubboTelemetryBuilder builder(OpenTelemetry openTelemetry) { this.clientInstrumenter = clientInstrumenter; } - /** - * Returns a new Dubbo {@link Filter} that traces Dubbo RPC invocations. - * - * @deprecated Use {@link #newClientFilter} and {@link #newServerFilter} instead. - */ - @Deprecated - public Filter newFilter() { - return TracingFilter.newFilter(serverInstrumenter, clientInstrumenter); - } - /** Returns a new Dubbo client {@link Filter} that traces Dubbo RPC invocations. */ public Filter newClientFilter() { - return TracingFilter.newClientFilter(clientInstrumenter); + return new TracingFilter(clientInstrumenter, true); } /** Returns a new Dubbo server {@link Filter} that traces Dubbo RPC invocations. */ public Filter newServerFilter() { - return TracingFilter.newServerFilter(serverInstrumenter); + return new TracingFilter(serverInstrumenter, false); } } diff --git a/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/TracingFilter.java b/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/TracingFilter.java index feced63c0bf0..e8068cabaf90 100644 --- a/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/TracingFilter.java +++ b/instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/TracingFilter.java @@ -18,52 +18,13 @@ final class TracingFilter implements Filter { - private final InstrumenterSupplier instrumenterSupplier; + private final Instrumenter instrumenter; - private TracingFilter(InstrumenterSupplier instrumenterSupplier) { - this.instrumenterSupplier = instrumenterSupplier; - } - - static TracingFilter newClientFilter(Instrumenter clientInstrumenter) { - return newFilter(clientInstrumenter, true); - } - - static TracingFilter newServerFilter(Instrumenter serverInstrumenter) { - return newFilter(serverInstrumenter, false); - } - - private static TracingFilter newFilter( - Instrumenter instrumenter, boolean isClientSide) { - return new TracingFilter( - new InstrumenterSupplier() { - - @Override - public Instrumenter get(RpcContext rpcContext) { - return instrumenter; - } + private final boolean isClientSide; - @Override - public boolean isClientSide(RpcContext rpcContext) { - return isClientSide; - } - }); - } - - static TracingFilter newFilter( - Instrumenter serverInstrumenter, - Instrumenter clientInstrumenter) { - return new TracingFilter( - new InstrumenterSupplier() { - @Override - public Instrumenter get(RpcContext rpcContext) { - return rpcContext.isConsumerSide() ? clientInstrumenter : serverInstrumenter; - } - - @Override - public boolean isClientSide(RpcContext rpcContext) { - return rpcContext.isConsumerSide(); - } - }); + TracingFilter(Instrumenter instrumenter, boolean isClientSide) { + this.instrumenter = instrumenter; + this.isClientSide = isClientSide; } @Override @@ -78,7 +39,6 @@ public Result invoke(Invoker invoker, Invocation invocation) { return invoker.invoke(invocation); } - Instrumenter instrumenter = instrumenterSupplier.get(rpcContext); Context parentContext = Context.current(); DubboRequest request = DubboRequest.create((RpcInvocation) invocation, rpcContext); @@ -91,7 +51,7 @@ public Result invoke(Invoker invoker, Invocation invocation) { boolean isSynchronous = true; try (Scope ignored = context.makeCurrent()) { result = invoker.invoke(invocation); - if (instrumenterSupplier.isClientSide(rpcContext)) { + if (isClientSide) { CompletableFuture future = rpcContext.getCompletableFuture(); if (future != null) { isSynchronous = false; @@ -108,10 +68,4 @@ public Result invoke(Invoker invoker, Invocation invocation) { } return result; } - - private interface InstrumenterSupplier { - Instrumenter get(RpcContext rpcContext); - - boolean isClientSide(RpcContext rpcContext); - } }