You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ro...@apache.org on 2023/04/14 14:35:40 UTC
[activemq-artemis] branch main updated (fc971b12ef -> 05f5af6eb1)
This is an automated email from the ASF dual-hosted git repository.
robbie pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from fc971b12ef ARTEMIS-4238 transactionTimeout ActivationConfigProperty is no longer working.
new 114b88a120 ARTEMIS-4242, ARTEMIS-4082: isolate testNonBlockingAckPerf to its own queues to stop poisoning testDupsOKAcknowledgeQueue
new 05f5af6eb1 ARTEMIS-4082: delete duplicate test, same as testDupsOKAcknowledgeQueue
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../artemis/jms/tests/AcknowledgementTest.java | 68 ++--------------------
1 file changed, 4 insertions(+), 64 deletions(-)
[activemq-artemis] 02/02: ARTEMIS-4082: delete duplicate test, same as testDupsOKAcknowledgeQueue
Posted by ro...@apache.org.
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 <ro...@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();
[activemq-artemis] 01/02: ARTEMIS-4242, ARTEMIS-4082: isolate testNonBlockingAckPerf to its own queues to stop poisoning testDupsOKAcknowledgeQueue
Posted by ro...@apache.org.
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 114b88a12060278808e61ed4f3ea07d6dc32cad3
Author: Robbie Gemmell <ro...@apache.org>
AuthorDate: Fri Apr 14 15:08:46 2023 +0100
ARTEMIS-4242, ARTEMIS-4082: isolate testNonBlockingAckPerf to its own queues to stop poisoning testDupsOKAcknowledgeQueue
---
.../apache/activemq/artemis/jms/tests/AcknowledgementTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 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 81167981b7..a843643316 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
@@ -1307,11 +1307,11 @@ public class AcknowledgementTest extends JMSTestCase {
int messageCount = 100;
- long sendT1 = send(cf1, queue1, messageCount);
- long sendT2 = send(cf2, queue2, messageCount);
+ long sendT1 = send(cf1, queue3, messageCount);
+ long sendT2 = send(cf2, queue4, messageCount);
- long time1 = consume(cf1, queue1, messageCount);
- long time2 = consume(cf2, queue2, messageCount);
+ long time1 = consume(cf1, queue3, messageCount);
+ long time2 = consume(cf2, queue4, messageCount);
logger.debug("BlockOnAcknowledge=false MessageCount={} TimeToConsume={}", messageCount, time1);
logger.debug("BlockOnAcknowledge=true MessageCount={} TimeToConsume={}", messageCount, time2);