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

clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/artemis.git


The following commit(s) were added to refs/heads/main by this push:
     new 5647ebb0ed NO-JIRA fixing intermittent failure on 
AuditLoggeAMQPMutualSSLTest
5647ebb0ed is described below

commit 5647ebb0ed97be4bcda024e2f4e48dbc721b3081
Author: Clebert Suconic <[email protected]>
AuthorDate: Mon Apr 6 17:31:51 2026 -0400

    NO-JIRA fixing intermittent failure on AuditLoggeAMQPMutualSSLTest
---
 .../artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java
 
b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java
index 286ffb30e4..a1f400faeb 100644
--- 
a/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java
+++ 
b/tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java
@@ -64,16 +64,18 @@ public class AuditLoggerAMQPMutualSSLTest extends 
AuditLoggerTestBase {
 
       ConnectionFactory connectionFactory = new 
JmsConnectionFactory(remoteUri);
       try (Connection connection = connectionFactory.createConnection()) {
-         Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+         Session session = connection.createSession(true, 
Session.SESSION_TRANSACTED);
          Queue queue = session.createQueue("exampleQueue");
          MessageProducer sender = session.createProducer(queue);
          TextMessage stm = session.createTextMessage("Hello world ");
          stm.setStringProperty("foo", "bar");
          sender.send(stm);
+         session.commit();
          MessageConsumer consumer = session.createConsumer(queue);
          connection.start();
          Message m = consumer.receive(500);
          assertNotNull(m);
+         session.commit();
       }
 
       assertTrue(findLogRecord(getAuditLog(), "AMQ601715: User 
myUser(consumers,producers)@", "successfully authenticated"));


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to