Skip to content

Commit 1024227

Browse files
committed
Minor fix
1 parent d2e8c60 commit 1024227

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

instrumentation/failsafe-3.0/library/src/main/java/io/opentelemetry/instrumentation/failsafe/v3_0/RetryPolicyEventListenerBuilders.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,12 @@ static <R> EventListener<ExecutionCompletedEvent<R>> buildInstrumentedFailureLis
2727
LongHistogram attemptsHistogram,
2828
Attributes commonAttributes) {
2929
Attributes attributes = commonAttributes.toBuilder().put(OUTCOME_KEY, "failure").build();
30+
EventListener<ExecutionCompletedEvent<R>> userFailureListener = userConfig.getFailureListener();
3031
return e -> {
3132
executionCounter.add(1, attributes);
3233
attemptsHistogram.record(e.getAttemptCount(), attributes);
33-
if (userConfig.getFailureListener() != null) {
34-
userConfig.getFailureListener().accept(e);
34+
if (userFailureListener != null) {
35+
userFailureListener.accept(e);
3536
}
3637
};
3738
}
@@ -42,11 +43,12 @@ static <R> EventListener<ExecutionCompletedEvent<R>> buildInstrumentedSuccessLis
4243
LongHistogram attemptsHistogram,
4344
Attributes commonAttributes) {
4445
Attributes attributes = commonAttributes.toBuilder().put(OUTCOME_KEY, "success").build();
46+
EventListener<ExecutionCompletedEvent<R>> userSuccessListener = userConfig.getSuccessListener();
4547
return e -> {
4648
executionCounter.add(1, attributes);
4749
attemptsHistogram.record(e.getAttemptCount(), attributes);
48-
if (userConfig.getFailureListener() != null) {
49-
userConfig.getFailureListener().accept(e);
50+
if (userSuccessListener != null) {
51+
userSuccessListener.accept(e);
5052
}
5153
};
5254
}

0 commit comments

Comments
 (0)