Fix shared BulkheadRegistry

jd-opensource · Jan 5, 2025 · b048cc1 · b048cc1
1 parent 77bde45
commit b048cc1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...t/implement/flowcontrol/concurrencylimit/resilience4j/Resilience4jConcurrencyLimiter.java b/...t/implement/flowcontrol/concurrencylimit/resilience4j/Resilience4jConcurrencyLimiter.java
@@ -31,6 +31,8 @@
  */
 public class Resilience4jConcurrencyLimiter extends AbstractConcurrencyLimiter {
 
+    private static final BulkheadRegistry REGISTRY = BulkheadRegistry.ofDefaults();
+
     private final Bulkhead bulkhead;
 
     public Resilience4jConcurrencyLimiter(ConcurrencyLimitPolicy policy) {
@@ -39,8 +41,7 @@ public Resilience4jConcurrencyLimiter(ConcurrencyLimitPolicy policy) {
                 .maxConcurrentCalls(policy.getMaxConcurrency() == null ? 0 : policy.getMaxConcurrency())
                 .maxWaitDuration(Duration.ofMillis(policy.getMaxWaitMs() == null || policy.getMaxWaitMs() < 0 ? 0 : policy.getMaxWaitMs()))
                 .build();
-        BulkheadRegistry registry = BulkheadRegistry.of(config);
-        bulkhead = registry.bulkhead(policy.getName());
+        bulkhead = REGISTRY.bulkhead(policy.getName(), config);
     }
 
     @Override