You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@artemis.apache.org by gt...@apache.org on 2025/12/19 14:25:18 UTC
(artemis) branch main updated: NO-JIRA assert message added rather than present as it may have expired, fix typos
This is an automated email from the ASF dual-hosted git repository.
gtully pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/artemis.git
The following commit(s) were added to refs/heads/main by this push:
new d8abed4a03 NO-JIRA assert message added rather than present as it may have expired, fix typos
d8abed4a03 is described below
commit d8abed4a03821e2f72c9876f913a623984e48af2
Author: Gary Tully <ga...@gmail.com>
AuthorDate: Fri Dec 19 14:25:02 2025 +0000
NO-JIRA assert message added rather than present as it may have expired, fix typos
---
.../integration/amqp/AmqpExpiredMessageTest.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java
index 7a11767ee5..d95ec90b87 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java
@@ -351,7 +351,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
@Test
@Timeout(60)
- public void testSendMessageThatIsExiredUsingAbsoluteTimeWithLongTTL() throws Exception {
+ public void testSendMessageThatIsExpiredUsingAbsoluteTimeWithLongTTL() throws Exception {
AmqpClient client = createAmqpClient();
AmqpConnection connection = addConnection(client.connect());
AmqpSession session = connection.createSession();
@@ -419,7 +419,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
@Test
@Timeout(60)
- public void testSendMessageThatIsNotExpiredUsingAbsoluteTimeWithElspsedTTL() throws Exception {
+ public void testSendMessageThatIsNotExpiredUsingAbsoluteTimeWithElapsedTTL() throws Exception {
AmqpClient client = createAmqpClient();
AmqpConnection connection = addConnection(client.connect());
AmqpSession session = connection.createSession();
@@ -596,7 +596,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
sender.send(message);
Queue dlq = getProxyToQueue(getDeadLetterAddress());
- assertTrue(Wait.waitFor(() -> dlq.getMessageCount() > 0, 7000, 500), "Message not movied to DLQ");
+ assertTrue(Wait.waitFor(() -> dlq.getMessageCount() > 0, 7000, 500), "Message not moved to DLQ");
connection.close();
@@ -654,7 +654,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
logger.debug("*******************************************************************************************************************************");
Queue forward = getProxyToQueue(FORWARDING_ADDRESS);
- assertTrue(Wait.waitFor(() -> forward.getMessageCount() > 0, 7000, 500), "Message not diverted");
+ assertTrue(Wait.waitFor(() -> forward.getMessagesAdded() > 0, 7000, 500), "Message not diverted");
Queue dlq = getProxyToQueue(getDeadLetterAddress());
assertTrue(Wait.waitFor(() -> dlq.getMessageCount() > 0, 7000, 500), "Message not moved to DLQ");
@@ -708,7 +708,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
sender.send(message);
Queue dlqView = getProxyToQueue(getDeadLetterAddress());
- assertTrue(Wait.waitFor(() -> dlqView.getMessageCount() > 0, 7000, 200), "Message not movied to DLQ");
+ assertTrue(Wait.waitFor(() -> dlqView.getMessageCount() > 0, 7000, 200), "Message not moved to DLQ");
// Read and Modify the message for redelivery repeatedly
AmqpReceiver receiver = session.createReceiver(getDeadLetterAddress());
@@ -742,17 +742,17 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport {
@Test
@Timeout(60)
- public void testExpireThorughAddressSettings() throws Exception {
- testExpireThorughAddressSettings(false);
+ public void testExpireThroughAddressSettings() throws Exception {
+ testExpireThroughAddressSettings(false);
}
@Test
@Timeout(60)
- public void testExpireThorughAddressSettingsRebootServer() throws Exception {
- testExpireThorughAddressSettings(true);
+ public void testExpireThroughAddressSettingsRebootServer() throws Exception {
+ testExpireThroughAddressSettings(true);
}
- private void testExpireThorughAddressSettings(boolean reboot) throws Exception {
+ private void testExpireThroughAddressSettings(boolean reboot) throws Exception {
// Address configuration
AddressSettings addressSettings = new AddressSettings();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@artemis.apache.org
For additional commands, e-mail: commits-help@artemis.apache.org