Skip to content

Commit 2eef2b6

Browse files
rogerschlachterRobWin
authored andcommitted
Making a small change that would allow getting the builder, and thus allow adding a custom exception handler (ReactiveX#202)
1 parent 5ddac72 commit 2eef2b6

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

resilience4j-spring-boot/src/main/java/io/github/resilience4j/circuitbreaker/autoconfigure/CircuitBreakerProperties.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
*/
1717

1818
import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;
19+
import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig.*;
1920
import org.springframework.boot.context.properties.ConfigurationProperties;
2021
import org.springframework.stereotype.Component;
2122

@@ -50,11 +51,15 @@ public CircuitBreakerConfig createCircuitBreakerConfig(String backend) {
5051
}
5152

5253
private CircuitBreakerConfig createCircuitBreakerConfig(BackendProperties backendProperties) {
54+
return buildCircuitBreakerConfig(backendProperties).build();
55+
}
56+
57+
public Builder buildCircuitBreakerConfig(BackendProperties backendProperties) {
5358
if (backendProperties == null) {
54-
return CircuitBreakerConfig.ofDefaults();
59+
return new Builder();
5560
}
5661

57-
CircuitBreakerConfig.Builder circuitBreakerConfigBuilder = CircuitBreakerConfig.custom();
62+
Builder circuitBreakerConfigBuilder = CircuitBreakerConfig.custom();
5863

5964
if (backendProperties.getWaitInterval() != null) {
6065
circuitBreakerConfigBuilder.waitDurationInOpenState(Duration.ofMillis(backendProperties.getWaitInterval()));
@@ -71,7 +76,7 @@ private CircuitBreakerConfig createCircuitBreakerConfig(BackendProperties backen
7176
if (backendProperties.getRingBufferSizeInHalfOpenState() != null) {
7277
circuitBreakerConfigBuilder.ringBufferSizeInHalfOpenState(backendProperties.getRingBufferSizeInHalfOpenState());
7378
}
74-
return circuitBreakerConfigBuilder.build();
79+
return circuitBreakerConfigBuilder;
7580
}
7681

7782
public Map<String, BackendProperties> getBackends() {

0 commit comments

Comments
 (0)