Skip to content

Commit 5647ebb

Browse files
NO-JIRA fixing intermittent failure on AuditLoggeAMQPMutualSSLTest
1 parent 72feedd commit 5647ebb

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/logging/AuditLoggerAMQPMutualSSLTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,16 +64,18 @@ public void testAuditForProducerAndConsumer() throws Exception {
6464

6565
ConnectionFactory connectionFactory = new JmsConnectionFactory(remoteUri);
6666
try (Connection connection = connectionFactory.createConnection()) {
67-
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
67+
Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
6868
Queue queue = session.createQueue("exampleQueue");
6969
MessageProducer sender = session.createProducer(queue);
7070
TextMessage stm = session.createTextMessage("Hello world ");
7171
stm.setStringProperty("foo", "bar");
7272
sender.send(stm);
73+
session.commit();
7374
MessageConsumer consumer = session.createConsumer(queue);
7475
connection.start();
7576
Message m = consumer.receive(500);
7677
assertNotNull(m);
78+
session.commit();
7779
}
7880

7981
assertTrue(findLogRecord(getAuditLog(), "AMQ601715: User myUser(consumers,producers)@", "successfully authenticated"));

0 commit comments

Comments
 (0)