Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4389 The word "mesage" should be corrected to "message"

This commit is contained in:
Yashashree Chopada 2023-08-15 15:02:14 +05:30 committed by clebertsuconic
parent ea1a556299
commit ab3e67a24b
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
View File

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

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFlowControlFailTest.java
View File

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

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/TopicDurableTests.java
View File

@ -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++) {

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireFlowControlFailTest.java
View File

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