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();

Reply via email to