Skip to content

Commit 779169e

Browse files
otelbot[bot]laurit
andauthored
Review fixes for nats-2.17:javaagent (#18219)
Co-authored-by: otelbot <197425009+otelbot@users.noreply.github.com> Co-authored-by: Lauri Tulmin <ltulmin@splunk.com>
1 parent 27c9e8e commit 779169e

4 files changed

Lines changed: 9 additions & 7 deletions

File tree

instrumentation/nats/nats-2.17/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/nats/v2_17/CompletableFutureWrapper.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,7 @@
99
import io.opentelemetry.context.Scope;
1010
import java.util.concurrent.CompletableFuture;
1111

12-
public class CompletableFutureWrapper {
13-
14-
private CompletableFutureWrapper() {}
12+
class CompletableFutureWrapper {
1513

1614
public static <T> CompletableFuture<T> wrap(CompletableFuture<T> future, Context context) {
1715
CompletableFuture<T> result = new CompletableFuture<>();
@@ -28,4 +26,6 @@ public static <T> CompletableFuture<T> wrap(CompletableFuture<T> future, Context
2826

2927
return result;
3028
}
29+
30+
private CompletableFutureWrapper() {}
3131
}

instrumentation/nats/nats-2.17/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/nats/v2_17/MessageHandlerInstrumentation.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public static class AdviceScope {
4848
private final Context context;
4949
private final Scope scope;
5050

51-
public AdviceScope(NatsRequest request, Context context, Scope scope) {
51+
private AdviceScope(NatsRequest request, Context context, Scope scope) {
5252
this.request = request;
5353
this.context = context;
5454
this.scope = scope;
@@ -72,13 +72,15 @@ public void end(@Nullable Throwable throwable) {
7272
}
7373

7474
@Advice.OnMethodEnter(suppress = Throwable.class, inline = false)
75+
@Nullable
7576
public static AdviceScope onEnter(@Advice.Argument(0) Message message) {
7677
return AdviceScope.start(message);
7778
}
7879

7980
@Advice.OnMethodExit(onThrowable = Throwable.class, suppress = Throwable.class, inline = false)
8081
public static void onExit(
81-
@Advice.Thrown @Nullable Throwable throwable, @Advice.Enter AdviceScope adviceScope) {
82+
@Advice.Thrown @Nullable Throwable throwable,
83+
@Advice.Enter @Nullable AdviceScope adviceScope) {
8284
if (adviceScope != null) {
8385
adviceScope.end(throwable);
8486
}

instrumentation/nats/nats-2.17/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/nats/v2_17/NatsSingletons.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import io.opentelemetry.javaagent.bootstrap.internal.ExperimentalConfig;
1515
import java.util.List;
1616

17-
public class NatsSingletons {
17+
class NatsSingletons {
1818

1919
private static final List<String> capturedHeaders =
2020
ExperimentalConfig.get().getMessagingHeaders();

instrumentation/nats/nats-2.17/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/nats/v2_17/SpanFinisher.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
import io.opentelemetry.instrumentation.nats.v2_17.internal.NatsRequest;
1313
import java.util.function.BiConsumer;
1414

15-
public class SpanFinisher implements BiConsumer<Message, Throwable> {
15+
class SpanFinisher implements BiConsumer<Message, Throwable> {
1616
private final Instrumenter<NatsRequest, NatsRequest> instrumenter;
1717
private final Context context;
1818
private final Connection connection;

0 commit comments

Comments
 (0)