This is an automated email from the ASF dual-hosted git repository. robbie pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 05f5af6eb1fbdbf0f640f1252454018d4cf58540 Author: Robbie Gemmell <rob...@apache.org> AuthorDate: Fri Apr 14 15:10:05 2023 +0100 ARTEMIS-4082: delete duplicate test, same as testDupsOKAcknowledgeQueue --- .../artemis/jms/tests/AcknowledgementTest.java | 60 ---------------------- 1 file changed, 60 deletions(-) diff --git a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java index a843643316..cd9323f078 100644 --- a/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java +++ b/tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/AcknowledgementTest.java @@ -635,66 +635,6 @@ public class AcknowledgementTest extends JMSTestCase { } - /* - * Send some messages, consume them and verify the messages are not sent upon recovery - */ - @Test - public void testLazyAcknowledge() throws Exception { - Connection conn = createConnection(); - - Session producerSess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE); - MessageProducer producer = producerSess.createProducer(queue1); - - Session consumerSess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE); - MessageConsumer consumer = consumerSess.createConsumer(queue1); - conn.start(); - - final int NUM_MESSAGES = 20; - - // Send some messages - for (int i = 0; i < NUM_MESSAGES; i++) { - Message m = producerSess.createMessage(); - producer.send(m); - } - - assertRemainingMessages(NUM_MESSAGES); - - logger.trace("Sent messages"); - - int count = 0; - - Message m = null; - for (int i = 0; i < NUM_MESSAGES; i++) { - m = consumer.receive(200); - if (m == null) { - break; - } - count++; - } - - ProxyAssertSupport.assertNotNull(m); - - assertRemainingMessages(NUM_MESSAGES); - - logger.trace("Received {} messages", count); - - ProxyAssertSupport.assertEquals(count, NUM_MESSAGES); - - consumerSess.recover(); - - logger.trace("Session recover called"); - - m = consumer.receiveNoWait(); - - logger.trace("Message is: {}", m); - - ProxyAssertSupport.assertNull(m); - - conn.close(); - - assertRemainingMessages(0); - } - @Test public void testMessageListenerAutoAck() throws Exception { Connection conn = createConnection();