Fixed result of AbstractCommand.isCircuitBreakerOpen() in light of fo…

…rced-open/closed properties
Netflix · Apr 23, 2015 · 0afc56c · 0afc56c
1 parent ce32295
commit 0afc56c
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 2 deletions.
diff --git a/hystrix-core/src/main/java/com/netflix/hystrix/AbstractCommand.java b/hystrix-core/src/main/java/com/netflix/hystrix/AbstractCommand.java
@@ -1832,11 +1832,22 @@ protected String getLogMessagePrefix() {
     /**
      * Whether the 'circuit-breaker' is open meaning that <code>execute()</code> will immediately return
      * the <code>getFallback()</code> response and not attempt a HystrixCommand execution.
-     * 
+     *
+     * 4 columns are ForcedOpen | ForcedClosed | CircuitBreaker open due to health ||| Expected Result
+     *
+     * T | T | T ||| OPEN (true)
+     * T | T | F ||| OPEN (true)
+     * T | F | T ||| OPEN (true)
+     * T | F | F ||| OPEN (true)
+     * F | T | T ||| CLOSED (false)
+     * F | T | F ||| CLOSED (false)
+     * F | F | T ||| OPEN (true)
+     * F | F | F ||| CLOSED (false)
+     *
      * @return boolean
      */
     public boolean isCircuitBreakerOpen() {
-        return circuitBreaker.isOpen();
+        return properties.circuitBreakerForceOpen().get() || (!properties.circuitBreakerForceClosed().get() && circuitBreaker.isOpen());
     }
 
     /**

diff --git a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixCommandTest.java b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixCommandTest.java
@@ -702,6 +702,30 @@ protected Boolean getFallback() {
         assertTrue(cmd.isCircuitBreakerOpen());
     }
 
+    /**
+     * Tests that the circuit-breaker reports itself as "CLOSED" if set as forced-closed
+     */
+    @Test
+    public void testCircuitBreakerReportsClosedIfForcedClosed() {
+        HystrixCommand<Boolean> cmd = new HystrixCommand<Boolean>(HystrixCommand.Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("GROUP")).andCommandPropertiesDefaults(
+                new HystrixCommandProperties.Setter().withCircuitBreakerForceOpen(false).withCircuitBreakerForceClosed(true))) {
+
+            @Override
+            protected Boolean run() throws Exception {
+                return true;
+            }
+
+            @Override
+            protected Boolean getFallback() {
+                return false;
+            }
+        };
+
+        assertTrue(cmd.execute());
+        System.out.println("RESULT : " + cmd.getExecutionEvents());
+        assertFalse(cmd.isCircuitBreakerOpen());
+    }
+
     /**
      * Test that the circuit-breaker will 'trip' and prevent command execution on subsequent calls.
      */