diff --git a/pom.xml b/pom.xml index 675da4dd..63347877 100644 --- a/pom.xml +++ b/pom.xml @@ -80,14 +80,14 @@ io.opentelemetry opentelemetry-bom - 1.12.0 + 1.22.0 pom import io.opentelemetry.instrumentation opentelemetry-instrumentation-bom-alpha - 1.12.0-alpha + 1.22.0-alpha pom import diff --git a/src/main/java/org/hyperledger/fabric/sdk/Endpoint.java b/src/main/java/org/hyperledger/fabric/sdk/Endpoint.java index fb290976..02d57296 100644 --- a/src/main/java/org/hyperledger/fabric/sdk/Endpoint.java +++ b/src/main/java/org/hyperledger/fabric/sdk/Endpoint.java @@ -45,7 +45,7 @@ import io.grpc.netty.shaded.io.netty.handler.ssl.SslContextBuilder; import io.grpc.netty.shaded.io.netty.handler.ssl.SslProvider; import io.opentelemetry.api.OpenTelemetry; -import io.opentelemetry.instrumentation.grpc.v1_6.GrpcTracing; +import io.opentelemetry.instrumentation.grpc.v1_6.GrpcTelemetry; import org.apache.commons.codec.binary.Hex; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -71,7 +71,7 @@ class Endpoint { private static final String SSLPROVIDER = Config.getConfig().getDefaultSSLProvider(); private static final String SSLNEGOTIATION = Config.getConfig().getDefaultSSLNegotiationType(); private static final OpenTelemetry openTelemetry = Config.getConfig().getOpenTelemetry(); - private static final GrpcTracing grpcTracing = GrpcTracing.create(openTelemetry); + private static final GrpcTelemetry grpcTelemetry = GrpcTelemetry.create(openTelemetry); private final String addr; private final int port; @@ -241,7 +241,7 @@ class Endpoint { } try { - ClientInterceptor clientInterceptor = grpcTracing.newClientInterceptor(); + ClientInterceptor clientInterceptor = grpcTelemetry.newClientInterceptor(); if (protocol.equalsIgnoreCase("grpc")) { this.channelBuilder = NettyChannelBuilder.forAddress(addr, port).negotiationType(NegotiationType.PLAINTEXT).intercept(clientInterceptor); addNettyBuilderProps(channelBuilder, properties);