You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@artemis.apache.org by cl...@apache.org on 2026/04/06 21:33:14 UTC
(artemis) branch main updated: NO-JIRA fixing intermittent failure on AuditLoggeAMQPMutualSSLTest
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 <cl...@apache.org>
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: commits-unsubscribe@artemis.apache.org
For additional commands, e-mail: commits-help@artemis.apache.org