Return-Path: X-Original-To: apmail-zest-commits-archive@minotaur.apache.org Delivered-To: apmail-zest-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A7EC71859A for ; Fri, 24 Apr 2015 06:36:14 +0000 (UTC) Received: (qmail 23899 invoked by uid 500); 24 Apr 2015 06:36:14 -0000 Delivered-To: apmail-zest-commits-archive@zest.apache.org Received: (qmail 23846 invoked by uid 500); 24 Apr 2015 06:36:14 -0000 Mailing-List: contact commits-help@zest.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@zest.apache.org Delivered-To: mailing list commits@zest.apache.org Received: (qmail 23689 invoked by uid 99); 24 Apr 2015 06:36:14 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Apr 2015 06:36:14 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 3A810E17FA; Fri, 24 Apr 2015 06:36:14 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: niclas@apache.org To: commits@zest.apache.org Date: Fri, 24 Apr 2015 06:36:17 -0000 Message-Id: <446414e732744f529dc0a8d03b480dd9@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [04/50] [abbrv] zest-qi4j git commit: CircuitBreaker: use Awaitility in test instead of Thread.sleep CircuitBreaker: use Awaitility in test instead of Thread.sleep Project: http://git-wip-us.apache.org/repos/asf/zest-qi4j/repo Commit: http://git-wip-us.apache.org/repos/asf/zest-qi4j/commit/5968ab9d Tree: http://git-wip-us.apache.org/repos/asf/zest-qi4j/tree/5968ab9d Diff: http://git-wip-us.apache.org/repos/asf/zest-qi4j/diff/5968ab9d Branch: refs/heads/master Commit: 5968ab9d9ee44ed02cfb2368975a1c7d7bf4c820 Parents: 1acd403 Author: Paul Merlin Authored: Thu Feb 20 22:17:42 2014 +0100 Committer: Paul Merlin Committed: Thu Feb 20 22:17:42 2014 +0100 ---------------------------------------------------------------------- libraries/circuitbreaker/build.gradle | 14 ++++++------ .../circuitbreaker/CircuitBreakerTest.java | 24 +++++++++++++++----- 2 files changed, 25 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/zest-qi4j/blob/5968ab9d/libraries/circuitbreaker/build.gradle ---------------------------------------------------------------------- diff --git a/libraries/circuitbreaker/build.gradle b/libraries/circuitbreaker/build.gradle index 597eaf6..8070a77 100644 --- a/libraries/circuitbreaker/build.gradle +++ b/libraries/circuitbreaker/build.gradle @@ -3,17 +3,17 @@ description = "Qi4j Circuit Breaker Library provides a framework for connecting jar { manifest {name = "Qi4j Library - Circuit Breaker"}} dependencies { - compile(project(":org.qi4j.core:org.qi4j.core.api")) - compile( project(':org.qi4j.libraries:org.qi4j.library.jmx' ) ) + compile project( ':org.qi4j.core:org.qi4j.core.api' ) + compile project( ':org.qi4j.libraries:org.qi4j.library.jmx' ) - testCompile(project(":org.qi4j.core:org.qi4j.core.testsupport")) + testCompile project( ':org.qi4j.core:org.qi4j.core.testsupport' ) + testCompile libraries.awaitility - testRuntime(project(":org.qi4j.core:org.qi4j.core.runtime")) - testRuntime(libraries.logback) + testRuntime project( ':org.qi4j.core:org.qi4j.core.runtime' ) + testRuntime libraries.logback } -task(runSample, dependsOn: 'testClasses', type: JavaExec) { +task( runSample, dependsOn: 'testClasses', type: JavaExec ) { main = 'org.qi4j.library.circuitbreaker.jmx.CircuitBreakerManagementTest' classpath = sourceSets.test.runtimeClasspath } - http://git-wip-us.apache.org/repos/asf/zest-qi4j/blob/5968ab9d/libraries/circuitbreaker/src/test/java/org/qi4j/library/circuitbreaker/CircuitBreakerTest.java ---------------------------------------------------------------------- diff --git a/libraries/circuitbreaker/src/test/java/org/qi4j/library/circuitbreaker/CircuitBreakerTest.java b/libraries/circuitbreaker/src/test/java/org/qi4j/library/circuitbreaker/CircuitBreakerTest.java index 6977451..783237f 100644 --- a/libraries/circuitbreaker/src/test/java/org/qi4j/library/circuitbreaker/CircuitBreakerTest.java +++ b/libraries/circuitbreaker/src/test/java/org/qi4j/library/circuitbreaker/CircuitBreakerTest.java @@ -20,10 +20,14 @@ import java.beans.PropertyChangeListener; import java.beans.PropertyVetoException; import java.beans.VetoableChangeListener; import java.io.IOException; +import java.util.concurrent.Callable; import org.hamcrest.CoreMatchers; import org.junit.Before; import org.junit.Test; +import static com.jayway.awaitility.Awaitility.await; +import static com.jayway.awaitility.Duration.FIVE_HUNDRED_MILLISECONDS; +import static org.hamcrest.core.Is.is; import static org.junit.Assert.assertThat; /** @@ -126,12 +130,8 @@ public class CircuitBreakerTest // END SNIPPET: direct assertThat( cb.status(), CoreMatchers.equalTo( CircuitBreaker.Status.off ) ); - try { - System.out.println( "Wait..." ); - Thread.sleep( 300 ); - } catch ( InterruptedException e ) { - // Ignore - } + System.out.println( "Wait..." ); + await().atMost( FIVE_HUNDRED_MILLISECONDS ).until( circuitBreakerStatus(), is( CircuitBreaker.Status.on ) ); // START SNIPPET: direct // CircuitBreaker is back on @@ -139,6 +139,18 @@ public class CircuitBreakerTest // END SNIPPET: direct assertThat( cb.status(), CoreMatchers.equalTo( CircuitBreaker.Status.on ) ); } + + private Callable circuitBreakerStatus() + { + return new Callable() + { + @Override + public CircuitBreaker.Status call() throws Exception + { + return cb.status(); + } + }; + } @Test public void GivenCBWhenExceptionsAndSuccessesThenStatusIsOn()