adds boolean list (cherry picked from commit 9c3f88aa938e6a77a1829754efe58ba20a5256cc)
Project: http://git-wip-us.apache.org/repos/asf/tomee/repo Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/80f99ecb Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/80f99ecb Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/80f99ecb Branch: refs/heads/tomee-1.7.x Commit: 80f99ecbbe88b6425ec9e001262b42c83fc08d70 Parents: 0d26263 Author: Otavio Santana <[email protected]> Authored: Mon Dec 18 14:23:16 2017 -0300 Committer: Thiago Veronezi <[email protected]> Committed: Wed Jan 17 12:59:48 2018 -0500 ---------------------------------------------------------------------- .../openejb/core/mdb/PoolEndpointHandlerTest.java | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tomee/blob/80f99ecb/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java ---------------------------------------------------------------------- diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java index f3a1b9b..1a47f99 100644 --- a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java +++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java @@ -40,7 +40,9 @@ import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.XAConnectionFactory; +import java.util.List; import java.util.Properties; +import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; @@ -113,7 +115,7 @@ public class PoolEndpointHandlerTest { } } assertTrue(Listener.sync()); - Assert.assertTrue(Listener.COUNTER.get() <= 10); + Assert.assertTrue(Listener.COUNTER.get() == 10); } @@ -124,7 +126,7 @@ public class PoolEndpointHandlerTest { }) public static class Listener implements MessageListener { public static CountDownLatch latch; - public static boolean ok = false; + private static final List<Boolean> BOOLEANS = new CopyOnWriteArrayList<>(); static final AtomicLong COUNTER = new AtomicLong(); @@ -136,7 +138,8 @@ public class PoolEndpointHandlerTest { public void onMessage(final Message message) { try { try { - ok = TextMessage.class.isInstance(message) && TEXT.equals(TextMessage.class.cast(message).getText()); + boolean ok = TextMessage.class.isInstance(message) && TEXT.equals(TextMessage.class.cast(message).getText()); + BOOLEANS.add(ok); } catch (final JMSException e) { } } finally { @@ -146,12 +149,17 @@ public class PoolEndpointHandlerTest { public static void reset() { latch = new CountDownLatch(1000); - ok = false; + BOOLEANS.clear(); } public static boolean sync() throws InterruptedException { latch.await(1, TimeUnit.MINUTES); - return ok; + for (boolean result : BOOLEANS) { + if(!result) { + return false; + } + } + return true; } }
