Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Making test more resilient

This commit is contained in:
Clebert Suconic 2024-07-22 18:55:17 -04:00
parent 71187c475d
commit 41ec279e22
1 changed files with 2 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/PageCounterOnBridgeFailoverTest.java
View File

@ -44,8 +44,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import static org.junit.jupiter.api.Assertions.assertEquals;
public class PageCounterOnBridgeFailoverTest extends FailoverTestBase {
private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
@ -97,16 +95,10 @@ public class PageCounterOnBridgeFailoverTest extends FailoverTestBase {
logger.info("Waiting for dc1Backup1 to be alive");
Wait.waitFor(dc1Backup1::isActive, 15000);
logger.info("dc1Backup1 isAlive");
long messageCountNodeDC1 = getMessageCount(dc1Backup1, queueName0);
long messageCountNodeDC2 = getMessageCount(dc2Primary1, queueName0);
logger.info("Count in post office: " + (messageCountNodeDC1 + messageCountNodeDC2) + "messageCountNodeDC1:" + messageCountNodeDC1 + ", messageCountNodeDC2:" + messageCountNodeDC2 + " should be equal to: " + messageSent);
dc1Backup1.getClusterManager().deployBridge(bridgeConfiguration);
Wait.waitFor(() -> getMessageCount(dc2Primary1, queueName0) == messageSent);
messageCountNodeDC1 = getMessageCount(dc1Backup1, queueName0);
messageCountNodeDC2 = getMessageCount(dc2Primary1, queueName0);
logger.info("Count in post office: " + (messageCountNodeDC1 + messageCountNodeDC2) + "messageCountNodeDC1:" + messageCountNodeDC1 + ", messageCountNodeDC2:" + messageCountNodeDC2 + " should be equal to: " + messageSent);
assertEquals(messageSent, messageCountNodeDC2);
assertEquals(0, messageCountNodeDC1);
Wait.assertEquals(messageSent, () -> getMessageCount(dc2Primary1, queueName0));
Wait.assertEquals(0, () -> getMessageCount(dc1Backup1, queueName0));
} finally {
dc2Primary1.stop();
}