fix typo (#4802)

apache · Aug 10, 2022 · 79d89f7 · 79d89f7
1 parent ce27426
commit 79d89f7
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 11 deletions.
diff --git a/...tener/rmq/concurrent/RMQDelayListner.java → ...ener/rmq/concurrent/RMQDelayListener.java b/...tener/rmq/concurrent/RMQDelayListner.java → ...ener/rmq/concurrent/RMQDelayListener.java
@@ -17,8 +17,6 @@
 
 package org.apache.rocketmq.test.listener.rmq.concurrent;
 
-import java.util.Collection;
-import java.util.List;
 import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
 import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
 import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
@@ -28,10 +26,13 @@
 import org.apache.rocketmq.test.util.data.collect.DataCollector;
 import org.apache.rocketmq.test.util.data.collect.DataCollectorManager;
 
-public class RMQDelayListner extends AbstractListener implements MessageListenerConcurrently {
+import java.util.Collection;
+import java.util.List;
+
+public class RMQDelayListener extends AbstractListener implements MessageListenerConcurrently {
     private DataCollector msgDelayTimes = null;
 
-    public RMQDelayListner() {
+    public RMQDelayListener() {
         msgDelayTimes = DataCollectorManager.getInstance()
             .fetchDataCollector(RandomUtil.getStringByUUID());
     }

diff --git a/test/src/test/java/org/apache/rocketmq/test/delay/NormalMsgDelayIT.java b/test/src/test/java/org/apache/rocketmq/test/delay/NormalMsgDelayIT.java
@@ -17,18 +17,19 @@
 
 package org.apache.rocketmq.test.delay;
 
-import java.util.List;
 import org.apache.log4j.Logger;
 import org.apache.rocketmq.test.client.rmq.RMQNormalConsumer;
 import org.apache.rocketmq.test.client.rmq.RMQNormalProducer;
 import org.apache.rocketmq.test.factory.MQMessageFactory;
-import org.apache.rocketmq.test.listener.rmq.concurrent.RMQDelayListner;
+import org.apache.rocketmq.test.listener.rmq.concurrent.RMQDelayListener;
 import org.apache.rocketmq.test.util.VerifyUtils;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.List;
+
 public class NormalMsgDelayIT extends DelayConf {
     private static Logger logger = Logger.getLogger(NormalMsgDelayIT.class);
     protected int msgSize = 100;
@@ -41,7 +42,7 @@ public void setUp() {
         topic = initTopic();
         logger.info(String.format("use topic: %s;", topic));
         producer = getProducer(nsAddr, topic);
-        consumer = getConsumer(nsAddr, topic, "*", new RMQDelayListner());
+        consumer = getConsumer(nsAddr, topic, "*", new RMQDelayListener());
     }
 
     @After
@@ -62,7 +63,7 @@ public void testDelayLevel1() throws Exception {
             consumer.getListener().getAllMsgBody()));
         Assert.assertEquals("Timer is not correct", true,
             VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000,
-                ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes()));
+                ((RMQDelayListener) consumer.getListener()).getMsgDelayTimes()));
     }
 
     @Test
@@ -78,7 +79,7 @@ public void testDelayLevel2() {
             consumer.getListener().getAllMsgBody()));
         Assert.assertEquals("Timer is not correct", true,
             VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000,
-                ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes()));
+                ((RMQDelayListener) consumer.getListener()).getMsgDelayTimes()));
     }
 
     @Test
@@ -94,7 +95,7 @@ public void testDelayLevel3() {
             consumer.getListener().getAllMsgBody()));
         Assert.assertEquals("Timer is not correct", true,
             VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000,
-                ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes()));
+                ((RMQDelayListener) consumer.getListener()).getMsgDelayTimes()));
     }
 
     @Test
@@ -110,6 +111,6 @@ public void testDelayLevel4() {
             consumer.getListener().getAllMsgBody()));
         Assert.assertEquals("Timer is not correct", true,
             VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000,
-                ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes()));
+                ((RMQDelayListener) consumer.getListener()).getMsgDelayTimes()));
     }
 }