20
20
21
21
import org .junit .Test ;
22
22
23
+ import java .util .Collections ;
23
24
import java .util .HashMap ;
24
25
import java .util .Map ;
25
26
@@ -80,14 +81,17 @@ public void testCreateWithCustomConfiguration() {
80
81
81
82
@ Test
82
83
public void testCreateWithConfigurationMap () {
84
+ CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig .custom ().failureRateThreshold (30f ).build ();
85
+ CircuitBreakerConfig customCircuitBreakerConfig = CircuitBreakerConfig .custom ().failureRateThreshold (40f ).build ();
83
86
Map <String , CircuitBreakerConfig > configs = new HashMap <>();
84
- configs .put ("default" , CircuitBreakerConfig . ofDefaults () );
85
- configs .put ("custom" , CircuitBreakerConfig . ofDefaults () );
87
+ configs .put ("default" , circuitBreakerConfig );
88
+ configs .put ("custom" , customCircuitBreakerConfig );
86
89
87
90
CircuitBreakerRegistry circuitBreakerRegistry = CircuitBreakerRegistry .of (configs );
88
91
89
92
assertThat (circuitBreakerRegistry .getDefaultConfig ()).isNotNull ();
90
- assertThat (circuitBreakerRegistry .getConfiguration ("custom" )).isNotNull ();
93
+ assertThat (circuitBreakerRegistry .getDefaultConfig ().getFailureRateThreshold ()).isEqualTo (30f );
94
+ assertThat (circuitBreakerRegistry .getConfiguration ("custom" )).isNotEmpty ();
91
95
}
92
96
93
97
@ Test
@@ -98,7 +102,8 @@ public void testAddConfiguration() {
98
102
circuitBreakerRegistry .addConfiguration ("someSharedConfig" , circuitBreakerConfig );
99
103
100
104
assertThat (circuitBreakerRegistry .getDefaultConfig ()).isNotNull ();
101
- assertThat (circuitBreakerRegistry .getConfiguration ("someSharedConfig" )).isNotNull ();
105
+ assertThat (circuitBreakerRegistry .getDefaultConfig ().getFailureRateThreshold ()).isEqualTo (50f );
106
+ assertThat (circuitBreakerRegistry .getConfiguration ("someSharedConfig" )).isNotEmpty ();
102
107
103
108
CircuitBreaker circuitBreaker = circuitBreakerRegistry .circuitBreaker ("name" , "someSharedConfig" );
104
109
assertThat (circuitBreaker .getCircuitBreakerConfig ()).isEqualTo (circuitBreakerConfig );
@@ -109,13 +114,12 @@ public void testAddConfiguration() {
109
114
public void testCreateWithConfigurationMapWithoutDefaultConfig () {
110
115
float failureRate = 30f ;
111
116
CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig .custom ().failureRateThreshold (failureRate ).build ();
112
- Map <String , CircuitBreakerConfig > configs = new HashMap <>();
113
- configs .put ("someSharedConfig" , circuitBreakerConfig );
114
117
115
- CircuitBreakerRegistry circuitBreakerRegistry = CircuitBreakerRegistry .of (configs );
118
+ CircuitBreakerRegistry circuitBreakerRegistry = CircuitBreakerRegistry .of (Collections . singletonMap ( "someSharedConfig" , circuitBreakerConfig ) );
116
119
117
120
assertThat (circuitBreakerRegistry .getDefaultConfig ()).isNotNull ();
118
- assertThat (circuitBreakerRegistry .getConfiguration ("someSharedConfig" )).isNotNull ();
121
+ assertThat (circuitBreakerRegistry .getDefaultConfig ().getFailureRateThreshold ()).isEqualTo (50f );
122
+ assertThat (circuitBreakerRegistry .getConfiguration ("someSharedConfig" )).isNotEmpty ();
119
123
120
124
CircuitBreaker circuitBreaker = circuitBreakerRegistry .circuitBreaker ("name" , "someSharedConfig" );
121
125
0 commit comments