This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
The following commit(s) were added to refs/heads/main by this push:
new 4199744426 Fix flakiness in AdvisoryViaNetworkTest by verifying peer
broker info on both sides for duplex network (#1867)
4199744426 is described below
commit 4199744426b936efccc6ef1037a0f9ad2ba6b4d1
Author: gurpartap3697 <[email protected]>
AuthorDate: Sun Apr 5 11:06:13 2026 +0530
Fix flakiness in AdvisoryViaNetworkTest by verifying peer broker info on
both sides for duplex network (#1867)
---
.../java/org/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 4ab5fb3ed0..554e40d54e 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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
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 class AdvisoryViaNetworkTest extends
JmsMultipleBrokersTestSupport {
startAllBrokers();
verifyPeerBrokerInfo(brokers.get("A"), 1);
+ verifyPeerBrokerInfo(brokers.get("B"), 1);
for (int i = 0; i < 10; i++) {
createConsumer("A", new ActiveMQTopic("A.FOO"));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
