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 <[email protected]>
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);