ARTEMIS-4082: delete duplicate test, same as testDupsOKAcknowledgeQueue

apache · Apr 14, 2023 · 05f5af6 · 05f5af6
1 parent 114b88a
commit 05f5af6
Showing 1 changed file with 0 additions and 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
@@ -635,66 +635,6 @@ public void testDupsOKAcknowledgeTopic() throws Exception {
 
    }
 
-   /*
-    * 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();