[ISSUE #1741] Rename takeMessags to takeMessages

Closes #1741

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java

@@ -452,7 +452,7 @@ public class ConsumeMessageOrderlyService implements ConsumeMessageService {
                         final int consumeBatchSize =
                             ConsumeMessageOrderlyService.this.defaultMQPushConsumer.getConsumeMessageBatchMaxSize();
 
-                        List<MessageExt> msgs = this.processQueue.takeMessags(consumeBatchSize);
+                        List<MessageExt> msgs = this.processQueue.takeMessages(consumeBatchSize);
                         defaultMQPushConsumerImpl.resetRetryAndNamespace(msgs, defaultMQPushConsumer.getConsumerGroup());
                         if (!msgs.isEmpty()) {
                             final ConsumeOrderlyContext context = new ConsumeOrderlyContext(this.messageQueue);

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java

@@ -296,7 +296,7 @@ public class ProcessQueue {
         }
     }
 
-    public List<MessageExt> takeMessags(final int batchSize) {
+    public List<MessageExt> takeMessages(final int batchSize) {
         List<MessageExt> result = new ArrayList<MessageExt>(batchSize);
         final long now = System.currentTimeMillis();
         try {

client/src/test/java/org/apache/rocketmq/client/impl/consumer/ProcessQueueTest.java

@@ -38,7 +38,7 @@ public class ProcessQueueTest {
 
         assertThat(pq.getMsgCount().get()).isEqualTo(100);
 
-        pq.takeMessags(10);
+        pq.takeMessages(10);
         pq.commit();
 
         assertThat(pq.getMsgCount().get()).isEqualTo(90);
@@ -55,7 +55,7 @@ public class ProcessQueueTest {
 
         assertThat(pq.getMsgSize().get()).isEqualTo(100 * 123);
 
-        pq.takeMessags(10);
+        pq.takeMessages(10);
         pq.commit();
 
         assertThat(pq.getMsgSize().get()).isEqualTo(90 * 123);
@@ -74,17 +74,17 @@ public class ProcessQueueTest {
 
         assertThat(processQueueInfo.getCachedMsgSizeInMiB()).isEqualTo(12);
 
-        pq.takeMessags(10000);
+        pq.takeMessages(10000);
         pq.commit();
         pq.fillProcessQueueInfo(processQueueInfo);
         assertThat(processQueueInfo.getCachedMsgSizeInMiB()).isEqualTo(10);
 
-        pq.takeMessags(10000);
+        pq.takeMessages(10000);
         pq.commit();
         pq.fillProcessQueueInfo(processQueueInfo);
         assertThat(processQueueInfo.getCachedMsgSizeInMiB()).isEqualTo(9);
 
-        pq.takeMessags(80000);
+        pq.takeMessages(80000);
         pq.commit();
         pq.fillProcessQueueInfo(processQueueInfo);
         assertThat(processQueueInfo.getCachedMsgSizeInMiB()).isEqualTo(0);