You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by tv...@apache.org on 2018/01/18 15:46:15 UTC
[20/50] tomee git commit: adds boolean list
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 <ot...@gmail.com>
Authored: Mon Dec 18 14:23:16 2017 -0300
Committer: Thiago Veronezi <th...@veronezi.org>
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;
}
}