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 ffb10c89f4 Fix copy-paste bug in MessageGroupLateArrivalsTest
assertion (#1680)
ffb10c89f4 is described below
commit ffb10c89f4c864582bbea141401009772ac84814
Author: Jean-Louis Monteiro <[email protected]>
AuthorDate: Fri Feb 13 06:50:55 2026 +0100
Fix copy-paste bug in MessageGroupLateArrivalsTest assertion (#1680)
testConsumerLateToBigPartyGetsNewGroup had two errors on line 220:
1. Checked messageCount.get("worker1") instead of "worker2"
2. Expected 2*perBatch (4) instead of perBatch (2)
---
.../java/org/apache/activemq/usecases/MessageGroupLateArrivalsTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/MessageGroupLateArrivalsTest.java
b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/MessageGroupLateArrivalsTest.java
index 4375386d94..e9261e202d 100644
---
a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/MessageGroupLateArrivalsTest.java
+++
b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/MessageGroupLateArrivalsTest.java
@@ -217,7 +217,7 @@ public class MessageGroupLateArrivalsTest {
log.info("worker2 received " + messageCount.get("worker2") + "
messages from groups " + messageGroups.get("worker2"));
assertEquals("worker2 received " + messageCount.get("worker2") + "
messages from groups " + messageGroups.get("worker2")
- , 2 * perBatch, messageCount.get("worker1").intValue());
+ , perBatch, messageCount.get("worker2").intValue());
assertEquals("worker2 received " + messageCount.get("worker2") + "
messages from groups " + messageGroups.get("worker2")
, 1, messageGroups.get("worker2").size());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
