(beam) branch master updated: Deflake JmsIO authentication tests (#39920)

[radek]

This is an automated email from the ASF dual-hosted git repository.

stankiewicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new aa35a98a681 Deflake JmsIO authentication tests (#39920)
aa35a98a681 is described below

commit aa35a98a6814c031eac8f843b271c7e1fa80afe8
Author: Bruno Volpato <brunocvcu...@gmail.com>
AuthorDate: Mon Aug 31 04:39:35 2026 -0400

    Deflake JmsIO authentication tests (#39920)
    
    thank you
---
 .../io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java 
b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java
index d23b33873e1..d6cb134249a 100644
--- a/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java
+++ b/sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOTest.java
@@ -192,7 +192,8 @@ public class JmsIOTest {
 
   @Test
   public void testAuthenticationRequired() {
-    
pipeline.apply(JmsIO.read().withConnectionFactory(connectionFactory).withQueue(QUEUE));
+    // A topic produces one source, avoiding races between concurrent 
authentication failures.
+    
pipeline.apply(JmsIO.read().withConnectionFactory(connectionFactory).withTopic(TOPIC));
     String errorMessage =
         this.connectionFactoryClass == ActiveMQConnectionFactory.class
             ? "User name [null] or password is invalid."
@@ -205,7 +206,7 @@ public class JmsIOTest {
     pipeline.apply(
         JmsIO.read()
             .withConnectionFactory(connectionFactory)
-            .withQueue(QUEUE)
+            .withTopic(TOPIC)
             .withUsername(USERNAME)
             .withPassword("BAD"));