Repository: activemq-artemis Updated Branches: refs/heads/ARTEMIS-780 a33a047d4 -> b3acd1622
checkstyle Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/baa95aa4 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/baa95aa4 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/baa95aa4 Branch: refs/heads/ARTEMIS-780 Commit: baa95aa4c1fd1b2a51d2021fd3fe2806ed47c1df Parents: a33a047 Author: Martyn Taylor <mtay...@redhat.com> Authored: Thu Dec 1 15:46:51 2016 +0000 Committer: Martyn Taylor <mtay...@redhat.com> Committed: Thu Dec 1 15:46:51 2016 +0000 ---------------------------------------------------------------------- .../integration/addressing/AnycastTest.java | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/baa95aa4/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AnycastTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AnycastTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AnycastTest.java index bc39d05..9208386 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AnycastTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AnycastTest.java @@ -16,6 +16,8 @@ */ package org.apache.activemq.artemis.tests.integration.addressing; +import java.util.concurrent.TimeUnit; + import org.apache.activemq.artemis.api.core.SimpleString; import org.apache.activemq.artemis.api.core.TransportConfiguration; import org.apache.activemq.artemis.api.core.client.ActiveMQClient; @@ -34,8 +36,6 @@ import org.apache.activemq.artemis.utils.TimeUtils; import org.junit.Before; import org.junit.Test; -import java.util.concurrent.TimeUnit; - public class AnycastTest extends ActiveMQTestBase { private SimpleString baseAddress = new SimpleString("anycast.address"); @@ -88,10 +88,10 @@ public class AnycastTest extends ActiveMQTestBase { assertNull(consumer2.receive(200)); session.commit(); - assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num/2 == q1.getMessageCount())); - assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num/2 == q2.getMessageCount())); + assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num / 2 == q1.getMessageCount())); + assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num / 2 == q2.getMessageCount())); - ClientConsumer[] consumers = new ClientConsumer[] {consumer1, consumer2}; + ClientConsumer[] consumers = new ClientConsumer[]{consumer1, consumer2}; for (int i = 0; i < consumers.length; i++) { for (int j = 0; j < num / 2; j++) { @@ -136,8 +136,8 @@ public class AnycastTest extends ActiveMQTestBase { session.commit(); session.close(); - assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num/2 == q1.getMessageCount())); - assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num/2 == q2.getMessageCount())); + assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num / 2 == q1.getMessageCount())); + assertTrue(TimeUtils.waitOnBoolean(true, 2000, () -> num / 2 == q2.getMessageCount())); ClientSession session1 = sessionFactory.createSession(false, false); ClientSession session2 = sessionFactory.createSession(false, false); @@ -147,9 +147,9 @@ public class AnycastTest extends ActiveMQTestBase { consumer1 = session1.createConsumer(q1.getName()); consumer2 = session2.createConsumer(q2.getName()); - ClientConsumer[] consumers = new ClientConsumer[] {consumer1, consumer2}; - ClientSession[] sessions = new ClientSession[] {session1, session2}; - Queue[] queues = new Queue[] {q1, q2}; + ClientConsumer[] consumers = new ClientConsumer[]{consumer1, consumer2}; + ClientSession[] sessions = new ClientSession[]{session1, session2}; + Queue[] queues = new Queue[]{q1, q2}; for (int i = 0; i < consumers.length; i++) {
