diff --git a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java index c18a094d7..1446d0d69 100644 --- a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java +++ b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java @@ -992,6 +992,12 @@ public void run() { Thread t3 = new Thread(r3); t2.start(); + try { + Thread.sleep(100); + } catch (Throwable ex) { + fail(ex.getMessage()); + } + t3.start(); try { t2.join(); @@ -1005,6 +1011,9 @@ public void run() { fail("We expected an exception on the 2nd get"); } + System.out.println("CMD1 : " + command1.getExecutionEvents()); + System.out.println("CMD2 : " + command2.getExecutionEvents()); + System.out.println("CMD3 : " + command3.getExecutionEvents()); assertCommandExecutionEvents(command1, HystrixEventType.EMIT, HystrixEventType.SUCCESS); assertCommandExecutionEvents(command2, HystrixEventType.EMIT, HystrixEventType.SUCCESS); assertCommandExecutionEvents(command3, HystrixEventType.SEMAPHORE_REJECTED, HystrixEventType.FALLBACK_MISSING);