From commits-return-63535-archive-asf-public=cust-asf.ponee.io@activemq.apache.org Thu Jun 3 00:00:52 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id ED940180638 for ; Thu, 3 Jun 2021 02:00:51 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id 1EF004040B for ; Thu, 3 Jun 2021 00:00:51 +0000 (UTC) Received: (qmail 63489 invoked by uid 500); 3 Jun 2021 00:00:50 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 63475 invoked by uid 99); 3 Jun 2021 00:00:50 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Jun 2021 00:00:50 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 1455C81A86; Thu, 3 Jun 2021 00:00:49 +0000 (UTC) Date: Thu, 03 Jun 2021 00:00:48 +0000 To: "commits@activemq.apache.org" Subject: [activemq-artemis] branch main updated: NO-JIRA fixing intermittent failure with a Wait call MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <162267844875.4942.12687989835581440966@gitbox.apache.org> From: clebertsuconic@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: activemq-artemis X-Git-Refname: refs/heads/main X-Git-Reftype: branch X-Git-Oldrev: c993b5a0e9aa6cfdd20d7ec11d96641c2e8dd69b X-Git-Newrev: f380324ca3308ffde6a36b6681386f429ddd1134 X-Git-Rev: f380324ca3308ffde6a36b6681386f429ddd1134 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git The following commit(s) were added to refs/heads/main by this push: new f380324 NO-JIRA fixing intermittent failure with a Wait call f380324 is described below commit f380324ca3308ffde6a36b6681386f429ddd1134 Author: Clebert Suconic AuthorDate: Wed Jun 2 19:53:26 2021 -0400 NO-JIRA fixing intermittent failure with a Wait call --- .../artemis/tests/integration/client/TransactionalSendTest.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java index b72e7a9..18d0d15 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/TransactionalSendTest.java @@ -25,6 +25,7 @@ import org.apache.activemq.artemis.api.core.client.ServerLocator; import org.apache.activemq.artemis.core.server.ActiveMQServer; import org.apache.activemq.artemis.core.server.Queue; import org.apache.activemq.artemis.tests.util.ActiveMQTestBase; +import org.apache.activemq.artemis.tests.util.Wait; import org.junit.Assert; import org.junit.Before; import org.junit.Test; @@ -68,9 +69,9 @@ public class TransactionalSendTest extends ActiveMQTestBase { for (int i = 0; i < numMessages; i++) { cp.send(session.createMessage(false)); } - Assert.assertEquals(numMessages, getMessageCount(q)); + Wait.assertEquals(numMessages, q::getMessageCount); session.commit(); - Assert.assertEquals(numMessages * 2, getMessageCount(q)); + Wait.assertEquals(numMessages * 2, q::getMessageCount); session.close(); } @@ -94,9 +95,9 @@ public class TransactionalSendTest extends ActiveMQTestBase { for (int i = 0; i < numMessages; i++) { cp.send(session.createMessage(false)); } - Assert.assertEquals(0, getMessageCount(q)); + Wait.assertEquals(0, q::getMessageCount); session.commit(); - Assert.assertEquals(numMessages, getMessageCount(q)); + Wait.assertEquals(numMessages, q::getMessageCount); session.close(); }