From b959ee466466848ceefc84a354789eb8409a857c Mon Sep 17 00:00:00 2001 From: gurpartap3697 Date: Wed, 1 Apr 2026 21:58:55 +0530 Subject: [PATCH] Fix flakiness in AdvisoryViaNetworkTest by verifying peer broker info on both sides for duplex network --- .../apache/activemq/usecases/AdvisoryViaNetworkTest.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/AdvisoryViaNetworkTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/AdvisoryViaNetworkTest.java index 4ab5fb3ed09..554e40d54ec 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/AdvisoryViaNetworkTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/AdvisoryViaNetworkTest.java @@ -105,6 +105,7 @@ public void testAdvisoryPrefetchSize() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); createConsumer("A", topic1); createConsumer("A", new ActiveMQTopic("A.FOO2")); @@ -142,6 +143,7 @@ public void testAdvisoryPrefetchSize1() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); createConsumer("A", topic1); createConsumer("A", new ActiveMQTopic("A.FOO2")); @@ -177,6 +179,7 @@ public void testAdvisoryPrefetchSizeNotSet() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); createConsumer("A", topic1); createConsumer("A", new ActiveMQTopic("A.FOO2")); @@ -211,6 +214,7 @@ public void testPrefetchSize1() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); createConsumer("A", topic1); createConsumer("A", new ActiveMQTopic("A.FOO2")); @@ -243,6 +247,7 @@ public void testAdvisoryPrefetchSizePercent() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); for (int i = 0; i < 10; i++) { createConsumer("A", new ActiveMQTopic("A.FOO")); @@ -270,6 +275,7 @@ public void testPrefetchSizePercent() throws Exception { startAllBrokers(); verifyPeerBrokerInfo(brokers.get("A"), 1); + verifyPeerBrokerInfo(brokers.get("B"), 1); for (int i = 0; i < 10; i++) { createConsumer("A", new ActiveMQTopic("A.FOO"));