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);

Reply via email to