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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
