This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push: new ab3e67a24b ARTEMIS-4389 The word "mesage" should be corrected to "message" ab3e67a24b is described below commit ab3e67a24bec11918798da3bb33287e09884f25e Author: Yashashree Chopada <136714452+ychop...@users.noreply.github.com> AuthorDate: Tue Aug 15 15:02:14 2023 +0530 ARTEMIS-4389 The word "mesage" should be corrected to "message" --- .../org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java | 2 +- .../artemis/tests/integration/amqp/AmqpFlowControlFailTest.java | 2 +- .../activemq/artemis/tests/integration/amqp/TopicDurableTests.java | 2 +- .../artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java index 72ef079664..2d72e4222f 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java @@ -1562,7 +1562,7 @@ public interface ActiveMQServerLogger { @LogMessage(id = 224119, value = "Unable to refresh security settings: {}", level = LogMessage.Level.WARN) void unableToRefreshSecuritySettings(String exceptionMessage); - @LogMessage(id = 224120, value = "Queue {} on Address {} has more messages than configured page limit. PageLimitMesages={} while currentValue={}", level = LogMessage.Level.WARN) + @LogMessage(id = 224120, value = "Queue {} on Address {} has more messages than configured page limit. PageLimitMessages={} while currentValue={}", level = LogMessage.Level.WARN) void pageFull(SimpleString queue, SimpleString address, Object pageLImitMessage, Object currentValue); @LogMessage(id = 224121, value = "Queue {} on Address {} is out of page limit now. We will issue a cleanup to check other queues.", level = LogMessage.Level.WARN) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFlowControlFailTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFlowControlFailTest.java index e640a0e22f..564460c0a3 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFlowControlFailTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFlowControlFailTest.java @@ -115,7 +115,7 @@ public class AmqpFlowControlFailTest { } @Test - public void testMesagesNotSent() throws Exception { + public void testMessagesNotSent() throws Exception { AmqpClient client = createAmqpClient(getBrokerAmqpConnectionURI()); AmqpConnection connection = client.connect(); int messagesSent = 0; diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/TopicDurableTests.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/TopicDurableTests.java index eedc23df5f..8cb35edc9d 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/TopicDurableTests.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/TopicDurableTests.java @@ -248,7 +248,7 @@ public class TopicDurableTests extends JMSClientTestSupport { resultsList.add(new CompletableFuture<>()); receivedResList.add(new ArrayList<>()); MessageListener myListener = message -> { - logger.debug("Mesages received{} count: {}", message, totalCount.get()); + logger.debug("Messages received{} count: {}", message, totalCount.get()); receivedResList.get(index).add(message); if (totalCount.decrementAndGet() == 0) { for (int j = 0; j < consumer.length; j++) { diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java index 2c66366428..600809d41c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java @@ -49,7 +49,7 @@ public class OpenWireFlowControlFailTest extends OpenWireTestBase { } @Test(timeout = 60000) - public void testMesagesNotSent() throws Exception { + public void testMessagesNotSent() throws Exception { AddressInfo addressInfo = new AddressInfo(SimpleString.toSimpleString("Test"), RoutingType.ANYCAST); server.addAddressInfo(addressInfo);