Skip to content

Commit ef93425

Browse files
committed
fixes problems with Bulkhead
1 parent 801861a commit ef93425

2 files changed

Lines changed: 3 additions & 19 deletions

File tree

resilience4j-bulkhead_2.x/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,5 +26,5 @@ jar {
2626
}
2727

2828
verifyInstrumentation {
29-
passes 'io.github.resilience4j:resilience4j-bulkhead:[2.0.0)'
29+
passes 'io.github.resilience4j:resilience4j-bulkhead:[2.0.0,)'
3030
}

resilience4j-bulkhead_2.x/src/main/java/io/github/resilience4j/bulkhead/Bulkhead.java

Lines changed: 2 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import io.github.resilience4j.core.functions.CheckedFunction;
2020
import io.github.resilience4j.core.functions.CheckedRunnable;
2121
import io.github.resilience4j.core.functions.CheckedSupplier;
22-
import io.github.resilience4j.core.functions.Either;
2322

2423
@Weave(type = MatchType.Interface)
2524
public abstract class Bulkhead {
@@ -68,13 +67,6 @@ public <T> T executeSupplier(Supplier<T> supplier) {
6867
return Weaver.callOriginal();
6968
}
7069

71-
@Trace
72-
public <T> Either<Exception, T> executeEitherSupplier(Supplier<Either<? extends Exception, T>> supplier) {
73-
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", getName(),
74-
"executeEitherSupplier");
75-
return Weaver.callOriginal();
76-
}
77-
7870
@Trace
7971
public void onComplete() {
8072
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", getName(),
@@ -98,7 +90,7 @@ public BulkheadConfig getBulkheadConfig() {
9890

9991
// Static methods
10092
@Trace
101-
static <T> CheckedSupplier<T> decorateCheckedSupplier(Bulkhead bulkhead, CheckedSupplier<T> supplier) {
93+
public static <T> CheckedSupplier<T> decorateCheckedSupplier(Bulkhead bulkhead, CheckedSupplier<T> supplier) {
10294
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", bulkhead.getName(),
10395
"decorateCheckedSupplier");
10496
return Weaver.callOriginal();
@@ -140,14 +132,6 @@ public static <T> Supplier<T> decorateSupplier(Bulkhead bulkhead, Supplier<T> su
140132
return Weaver.callOriginal();
141133
}
142134

143-
@Trace
144-
public static <T> Supplier<Either<Exception, T>> decorateEitherSupplier(Bulkhead bulkhead,
145-
Supplier<Either<? extends Exception, T>> supplier) {
146-
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", bulkhead.getName(),
147-
"decorateEitherSupplier");
148-
return Weaver.callOriginal();
149-
}
150-
151135
@Trace
152136
public static <T> Consumer<T> decorateConsumer(Bulkhead bulkhead, Consumer<T> consumer) {
153137
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", bulkhead.getName(),
@@ -177,7 +161,7 @@ public static <T, R> Function<T, R> decorateFunction(Bulkhead bulkhead, Function
177161
}
178162

179163
@Trace
180-
static <T, R> CheckedFunction<T, R> decorateCheckedFunction(Bulkhead bulkhead, CheckedFunction<T, R> function) {
164+
public static <T, R> CheckedFunction<T, R> decorateCheckedFunction(Bulkhead bulkhead, CheckedFunction<T, R> function) {
181165
NewRelic.getAgent().getTracedMethod().setMetricName("Custom", "Resilience4j", "Bulkhead", bulkhead.getName(),
182166
"decorateCheckedFunction");
183167
return Weaver.callOriginal();

0 commit comments

Comments
 (0)