diff --git a/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java b/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java index 3f185d3a16336fc77f6ec355681d2c77bf3ad078..7225cd6bd46203f84070a8a663e531013ef5c32f 100644 --- a/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java +++ b/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java @@ -33,12 +33,12 @@ public class RMQNormalConsumer extends AbstractMQConsumer { super(nsAddr, topic, subExpression, consumerGroup, listner); } - public AbstractListener getListner() { - return listner; + public AbstractListener getListener() { + return listener; } - public void setListner(AbstractListener listner) { - this.listner = listner; + public void setListener(AbstractListener listener) { + this.listener = listener; } public void create() { @@ -51,7 +51,7 @@ public class RMQNormalConsumer extends AbstractMQConsumer { logger.error("consumer subscribe failed!"); e.printStackTrace(); } - consumer.setMessageListener(listner); + consumer.setMessageListener(listener); } public void start() { @@ -79,7 +79,7 @@ public class RMQNormalConsumer extends AbstractMQConsumer { @Override public void clearMsg() { - this.listner.clearMsg(); + this.listener.clearMsg(); } public void restart() { diff --git a/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java b/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java index a077129ae38ecb58a54321a0d49e252b33fe70ea..22193bb4ba9cd6ffc97747195740264990dcc0dc 100644 --- a/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java +++ b/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java @@ -20,7 +20,7 @@ package org.apache.rocketmq.test.clientinterface; import org.apache.rocketmq.test.listener.AbstractListener; public abstract class AbstractMQConsumer implements MQConsumer { - protected AbstractListener listner = null; + protected AbstractListener listener = null; protected String nsAddr = null; protected String topic = null; protected String subExpression = null; @@ -31,11 +31,11 @@ public abstract class AbstractMQConsumer implements MQConsumer { } public AbstractMQConsumer(String nsAddr, String topic, String subExpression, - String consumerGroup, AbstractListener listner) { + String consumerGroup, AbstractListener listener) { this.topic = topic; this.subExpression = subExpression; this.consumerGroup = consumerGroup; - this.listner = listner; + this.listener = listener; this.nsAddr = nsAddr; } @@ -45,16 +45,16 @@ public abstract class AbstractMQConsumer implements MQConsumer { } public void setDebug() { - if (listner != null) { - listner.setDebug(true); + if (listener != null) { + listener.setDebug(true); } isDebug = true; } public void setDebug(boolean isDebug) { - if (listner != null) { - listner.setDebug(isDebug); + if (listener != null) { + listener.setDebug(isDebug); } this.isDebug = isDebug; @@ -65,12 +65,12 @@ public abstract class AbstractMQConsumer implements MQConsumer { this.subExpression = subExpression; } - public AbstractListener getListner() { - return listner; + public AbstractListener getListener() { + return listener; } - public void setListner(AbstractListener listner) { - this.listner = listner; + public void setListener(AbstractListener listener) { + this.listener = listener; } public String getNsAddr() { @@ -106,7 +106,7 @@ public abstract class AbstractMQConsumer implements MQConsumer { } public void clearMsg() { - listner.clearMsg(); + listener.clearMsg(); } } diff --git a/test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java b/test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java index 14da397e0ec5c0e96cfc9acbffd22d11c5180d3c..6a13049f7f368adff4c81534789d4ccae3bc94a3 100644 --- a/test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java +++ b/test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java @@ -30,16 +30,16 @@ import org.apache.rocketmq.test.util.TestUtil; public class AbstractListener extends MQCollector implements MessageListener { public static Logger logger = Logger.getLogger(AbstractListener.class); protected boolean isDebug = false; - protected String listnerName = null; + protected String listenerName = null; protected Collection allSendMsgs = null; public AbstractListener() { super(); } - public AbstractListener(String listnerName) { + public AbstractListener(String listenerName) { super(); - this.listnerName = listnerName; + this.listenerName = listenerName; } public AbstractListener(String originMsgCollector, String msgBodyCollector) { @@ -82,10 +82,10 @@ public class AbstractListener extends MQCollector implements MessageListener { } else { if (System.currentTimeMillis() - curTime >= timeoutMills) { logger.error(String.format("timeout but [%s] not recv all send messages!", - listnerName)); + listenerName)); break; } else { - logger.info(String.format("[%s] still [%s] msg not recv!", listnerName, + logger.info(String.format("[%s] still [%s] msg not recv!", listenerName, sendMsgs.size())); TestUtil.waitForMonment(500); } @@ -105,10 +105,10 @@ public class AbstractListener extends MQCollector implements MessageListener { } if (System.currentTimeMillis() - curTime >= timeoutMills) { logger.error(String.format("timeout but [%s] not recv all send messages!", - listnerName)); + listenerName)); break; } else { - logger.info(String.format("[%s] still [%s] msg not recv!", listnerName, + logger.info(String.format("[%s] still [%s] msg not recv!", listenerName, size - msgBodys.getDataSize())); TestUtil.waitForMonment(500); } diff --git a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQDelayListner.java b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQDelayListner.java index b4a08702513259e4ac2be3032e5f5e7d87ca4b2b..6d9892c79098d86396b7b2100d9167f9337bbb1f 100644 --- a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQDelayListner.java +++ b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQDelayListner.java @@ -49,7 +49,7 @@ public class RMQDelayListner extends AbstractListener implements MessageListener long recvTime = System.currentTimeMillis(); for (MessageExt msg : msgs) { if (isDebug) { - logger.info(listnerName + ":" + msg); + logger.info(listenerName + ":" + msg); } msgBodys.addData(new String(msg.getBody())); diff --git a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQNormalListner.java b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQNormalListner.java index 471fb4817ef80ef31977edec67322d6a38347165..679f8bd5d937824d9f668e8df9be6c56041c5c80 100644 --- a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQNormalListner.java +++ b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQNormalListner.java @@ -51,8 +51,8 @@ public class RMQNormalListner extends AbstractListener implements MessageListene for (MessageExt msg : msgs) { msgIndex.getAndIncrement(); if (isDebug) { - if (listnerName != null && listnerName != "") { - logger.info(listnerName + ":" + msgIndex.get() + ":" + if (listenerName != null && listenerName != "") { + logger.info(listenerName + ":" + msgIndex.get() + ":" + String.format("msgid:%s broker:%s queueId:%s offset:%s", msg.getMsgId(), msg.getStoreHost(), msg.getQueueId(), msg.getQueueOffset())); diff --git a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java index 91883d86340dd4d5d22323ca234d9addc6516c1e..85c61770e07475e2e9cf8d39e1e62b88c003e9b6 100644 --- a/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java +++ b/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java @@ -68,8 +68,8 @@ public class RMQOrderListener extends AbstractListener implements MessageListene ConsumeOrderlyContext context) { for (MessageExt msg : msgs) { if (isDebug) { - if (listnerName != null && listnerName != "") { - logger.info(listnerName + ": " + msg); + if (listenerName != null && listenerName != "") { + logger.info(listenerName + ": " + msg); } else { logger.info(msg); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java index fdafdf09dc66429332ef09429d07f3846a7e729d..835f746fd54d88d9d000978ac4418bbaf1097373 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java @@ -57,22 +57,22 @@ public class NormalMsgDynamicBalanceIT extends BaseConf { producer.send(msgSize); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener()); consumer2.shutdown(); producer.send(msgSize); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils.verifyBalance(msgSize, VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()).size() - msgSize, + consumer1.getListener().getAllUndupMsgBody()).size() - msgSize, VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size()); + consumer2.getListener().getAllUndupMsgBody()).size()); assertThat(balance).isEqualTo(true); } @@ -87,8 +87,8 @@ public class NormalMsgDynamicBalanceIT extends BaseConf { producer.send(msgSize); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner(), consumer3.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener(), consumer3.getListener()); consumer3.shutdown(); producer.clearMsg(); consumer1.clearMsg(); @@ -98,14 +98,14 @@ public class NormalMsgDynamicBalanceIT extends BaseConf { Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils.verifyBalance(msgSize, VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()).size(), + consumer1.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size()); + consumer2.getListener().getAllUndupMsgBody()).size()); assertThat(balance).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgStaticBalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgStaticBalanceIT.java index 117d64373cf5248f3a23cb7faad79317adf0f29e..9c9b25498acfba114d3ca1dfa2d9c82fa6d973f0 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgStaticBalanceIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgStaticBalanceIT.java @@ -61,14 +61,14 @@ public class NormalMsgStaticBalanceIT extends BaseConf { Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils.verifyBalance(msgSize, VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()).size(), + consumer1.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size()); + consumer2.getListener().getAllUndupMsgBody()).size()); assertThat(balance).isEqualTo(true); } @@ -88,22 +88,22 @@ public class NormalMsgStaticBalanceIT extends BaseConf { Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner(), - consumer4.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener(), + consumer4.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils .verifyBalance(msgSize, VerifyUtils .getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()) + consumer1.getListener().getAllUndupMsgBody()) .size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size(), + consumer2.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer3.getListner().getAllUndupMsgBody()).size(), + consumer3.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer4.getListner().getAllUndupMsgBody()).size()); + consumer4.getListener().getAllUndupMsgBody()).size()); assertThat(balance).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java index 32b13fd717f4a3d651e06ea352386ab778bbdc49..41408b82e9ea59a1315bf6a4d7a66ec511dfecbc 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java @@ -60,14 +60,14 @@ public class BroadCastNormalMsgNotRecvIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); RMQBroadCastConsumer consumer2 = getBroadCastConsumer(nsAddr, consumer1.getConsumerGroup(), topic, "*", new RMQNormalListner(group + "_2")); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), waitTime); - assertThat(consumer2.getListner().getAllMsgBody().size()).isEqualTo(0); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), waitTime); + assertThat(consumer2.getListener().getAllMsgBody().size()).isEqualTo(0); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvCrashIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvCrashIT.java index b878d099c4c039c60a67c146a1226fb27499d453..fc0cfce8d15bb8a3da142c82e7760fda134a4f63 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvCrashIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvCrashIT.java @@ -64,13 +64,13 @@ public class BroadCastNormalMsgRecvCrashIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); consumer2.shutdown(); @@ -81,9 +81,9 @@ public class BroadCastNormalMsgRecvCrashIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvFailIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvFailIT.java index 26c37f97e2810e07ed688f5763f74d89f13137b5..0d3f6fbba5ce3efc9517d69c6d7d03bab3a578b2 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvFailIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvFailIT.java @@ -63,10 +63,10 @@ public class BroadCastNormalMsgRecvFailIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvStartLaterIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvStartLaterIT.java index 027f6482f6fd0a092071f4af6a84d759a588301c..dd1db0b043e580fea7a32dc7a7e3e77f4f407614 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvStartLaterIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvStartLaterIT.java @@ -62,9 +62,9 @@ public class BroadCastNormalMsgRecvStartLaterIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); producer.clearMsg(); @@ -76,13 +76,13 @@ public class BroadCastNormalMsgRecvStartLaterIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgTwoDiffGroupRecvIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgTwoDiffGroupRecvIT.java index acbaf23b5f0d8eafbed4c4661fdc30ba1baa75a2..4fb5005f3af9c454f80303bf7a73d7a5a125790d 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgTwoDiffGroupRecvIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgTwoDiffGroupRecvIT.java @@ -65,14 +65,14 @@ public class BroadCastNormalMsgTwoDiffGroupRecvIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/NormalMsgTwoSameGroupConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/NormalMsgTwoSameGroupConsumerIT.java index 984c94123f1176f597ef07ef36e40f060fa0854e..76e69b3777ed64ac80464be1e298ae79e2731728 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/NormalMsgTwoSameGroupConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/NormalMsgTwoSameGroupConsumerIT.java @@ -64,14 +64,14 @@ public class NormalMsgTwoSameGroupConsumerIT extends BaseBroadCastIT { producer.send(msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/OrderMsgBroadCastIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/OrderMsgBroadCastIT.java index ac8fcf54a3bebf14cb99cafe2b85f85607ab4d98..2c9abc067fca1a4f323cec5f7ab5b78d0e1ae049 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/OrderMsgBroadCastIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/OrderMsgBroadCastIT.java @@ -64,12 +64,12 @@ public class OrderMsgBroadCastIT extends BaseBroadCastIT { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerFilterIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerFilterIT.java index a1a2ff7a0dceaff22aea78db658d7cba4b582c0d..0d3b1ca1e9f83adacebb29ce174bc7bae2aa886a 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerFilterIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerFilterIT.java @@ -65,14 +65,14 @@ public class BroadCastTwoConsumerFilterIT extends BaseBroadCastIT { producer.clearMsg(); producer.send(tag1, msgSize); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubDiffTagIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubDiffTagIT.java index 5c2e7fc110291bb8812f0043fce7fae4f8bc299f..155a0aa00d22c3de1d618323e09e8ac8c388810c 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubDiffTagIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubDiffTagIT.java @@ -62,14 +62,14 @@ public class BroadCastTwoConsumerSubDiffTagIT extends BaseBroadCastIT { producer.send(tag, msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubTagIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubTagIT.java index e4510dedcffe6d244053930d38e719a486328dec..e89464f7eabca24458d5f17b3331b6491701a81e 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubTagIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubTagIT.java @@ -62,14 +62,14 @@ public class BroadCastTwoConsumerSubTagIT extends BaseBroadCastIT { producer.send(tag, msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); - consumer2.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer2.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllMsgBody())) + consumer2.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddAndCrashIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddAndCrashIT.java index 303dfa0dec3b1f9a70328b94153e60ddfa5c0ddd..23248e3daf538b9289114f9f9b4c8f4e86711dc3 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddAndCrashIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddAndCrashIT.java @@ -65,11 +65,11 @@ public class DynamicAddAndCrashIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } @@ -93,11 +93,11 @@ public class DynamicAddAndCrashIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner(), consumer3.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener(), consumer3.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener()); assertThat(recvAll).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddConsumerIT.java index 46dbb70f70369343200d7fb04199b1b671ca1929..9ef79534d251280830897723bfe210e7a6598bb3 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddConsumerIT.java @@ -63,11 +63,11 @@ public class DynamicAddConsumerIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } @@ -87,11 +87,11 @@ public class DynamicAddConsumerIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner(), consumer3.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener(), consumer3.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener()); assertThat(recvAll).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicCrashConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicCrashConsumerIT.java index 807f950e87f71a83d05bec55ec739e76d377e803..1323720664b4500f379814c2e78fe2f5b90acdc7 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicCrashConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicCrashConsumerIT.java @@ -64,11 +64,11 @@ public class DynamicCrashConsumerIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } @@ -90,11 +90,11 @@ public class DynamicCrashConsumerIT extends BaseConf { asyncDefaultMQProducer.waitSendAll(waitTime * 6); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner(), consumer3.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener(), consumer3.getListener()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener()); assertThat(recvAll).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java index 7eef2ab0c4837c13ef1d4d3f4a5060f55bf67281..6c96e5ef8829ffceeae5ec6865bba7183a6054dc 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java @@ -20,9 +20,6 @@ package org.apache.rocketmq.test.client.consumer.filter; import org.apache.log4j.Logger; import org.apache.rocketmq.client.consumer.MessageSelector; import org.apache.rocketmq.test.base.BaseConf; -import org.apache.rocketmq.test.client.consumer.broadcast.BaseBroadCastIT; -import org.apache.rocketmq.test.client.consumer.broadcast.normal.NormalMsgTwoSameGroupConsumerIT; -import org.apache.rocketmq.test.client.rmq.RMQBroadCastConsumer; import org.apache.rocketmq.test.client.rmq.RMQNormalProducer; import org.apache.rocketmq.test.client.rmq.RMQSqlConsumer; import org.apache.rocketmq.test.factory.ConsumerFactory; @@ -64,11 +61,11 @@ public class SqlFilterIT extends BaseConf { producer.send("TagB", msgSize); producer.send("TagC", msgSize); Assert.assertEquals("Not all sent succeeded", msgSize * 3, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(msgSize * 2, consumeTime); + consumer.getListener().waitForMessageConsume(msgSize * 2, consumeTime); assertThat(producer.getAllMsgBody()) .containsAllIn(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); - assertThat(consumer.getListner().getAllMsgBody().size()).isEqualTo(msgSize * 2); + assertThat(consumer.getListener().getAllMsgBody().size()).isEqualTo(msgSize * 2); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/MulTagSubIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/MulTagSubIT.java index ecb204e62eb79b3211c8f171da6fcfcae6d7137f..37ccb4d204aeebd58c8d62464d349b288c432281 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/MulTagSubIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/MulTagSubIT.java @@ -61,10 +61,10 @@ public class MulTagSubIT extends BaseConf { new RMQNormalListner()); producer.send(tag, msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -83,10 +83,10 @@ public class MulTagSubIT extends BaseConf { producer.send(tag2Msgs); Assert.assertEquals("Not all sent succeeded", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), + consumer.getListener().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(MQMessageFactory.getMessageBody(tag2Msgs)); } @@ -104,10 +104,10 @@ public class MulTagSubIT extends BaseConf { Assert.assertEquals("Not all sent succeeded", msgSize * tags.length, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getAllTagMessageBody()); } @@ -125,11 +125,11 @@ public class MulTagSubIT extends BaseConf { Assert.assertEquals("Not all sent succeeded", msgSize * tags.length, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume( + consumer.getListener().waitForMessageConsume( tagMessage.getMessageBodyByTag(tags[0], tags[1]), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())).containsExactlyElementsIn( + consumer.getListener().getAllMsgBody())).containsExactlyElementsIn( tagMessage.getMessageBodyByTag(tags[0], tags[1])); } @@ -150,7 +150,7 @@ public class MulTagSubIT extends BaseConf { TestUtils.waitForSeconds(5); assertThat(VerifyUtils - .getFilterdMessage(producer.getAllMsgBody(), consumer.getListner().getAllMsgBody()) + .getFilterdMessage(producer.getAllMsgBody(), consumer.getListener().getAllMsgBody()) .size()).isEqualTo(0); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWith1ConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWith1ConsumerIT.java index f0a1d48834a4dbebb71682f689bf450c5d721135..1952f3056e91c2a0702ea77c1a277987e2f7cff1 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWith1ConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWith1ConsumerIT.java @@ -57,9 +57,9 @@ public class TagMessageWith1ConsumerIT extends BaseConf { RMQNormalConsumer consumer = getConsumer(nsAddr, topic, tag, new RMQNormalListner()); producer.send(tag, msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -71,10 +71,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { new RMQNormalListner()); producer.send(msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -87,10 +87,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { new RMQNormalListner()); producer.send(tag, msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -103,10 +103,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { new RMQNormalListner()); producer.send(tag, msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -119,10 +119,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { new RMQNormalListner()); producer.send(tag, msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -142,10 +142,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { producer.send(tag2Msgs); producer.send(10); Assert.assertEquals("Not all are sent", msgSize * 3, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -164,10 +164,10 @@ public class TagMessageWith1ConsumerIT extends BaseConf { producer.send(tag1Msgs); producer.send(tag2Msgs); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -187,11 +187,11 @@ public class TagMessageWith1ConsumerIT extends BaseConf { producer.send(tag2Msgs); producer.send(10); Assert.assertEquals("Not all are sent", msgSize * 3, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), + consumer.getListener().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(MQMessageFactory.getMessageBody(tag2Msgs)); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithMulConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithMulConsumerIT.java index 995bf416d8cae8458ffb71b0fd11b00d6757246c..8cc97f2f3254deb3eeed327d95cb82726e92a48a 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithMulConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithMulConsumerIT.java @@ -69,16 +69,16 @@ public class TagMessageWithMulConsumerIT extends BaseConf { producer.send(tag2Msgs); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumerTag1.getListner().waitForMessageConsume(MQMessageFactory.getMessageBody(tag1Msgs), + consumerTag1.getListener().waitForMessageConsume(MQMessageFactory.getMessageBody(tag1Msgs), consumeTime); - consumerTag2.getListner().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), + consumerTag2.getListener().waitForMessageConsume(MQMessageFactory.getMessageBody(tag2Msgs), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag1.getListner().getAllMsgBody())) + consumerTag1.getListener().getAllMsgBody())) .containsExactlyElementsIn(MQMessageFactory.getMessageBody(tag1Msgs)); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag2.getListner().getAllMsgBody())) + consumerTag2.getListener().getAllMsgBody())) .containsExactlyElementsIn(MQMessageFactory.getMessageBody(tag2Msgs)); } @@ -98,16 +98,16 @@ public class TagMessageWithMulConsumerIT extends BaseConf { Assert.assertEquals("Not all are sent", msgSize * tags.length, producer.getAllUndupMsgBody().size()); - consumerTag1.getListner().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), + consumerTag1.getListener().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), consumeTime); - consumerTag2.getListner().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[1]), + consumerTag2.getListener().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[1]), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag1.getListner().getAllMsgBody())) + consumerTag1.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getMessageBodyByTag(tags[0])); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag2.getListner().getAllMsgBody())) + consumerTag2.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getMessageBodyByTag(tags[1])); } @@ -129,16 +129,16 @@ public class TagMessageWithMulConsumerIT extends BaseConf { Assert.assertEquals("Not all are sent", msgSize * tags.length, producer.getAllUndupMsgBody().size()); - consumerTag1.getListner().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags), + consumerTag1.getListener().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags), consumeTime); - consumerTag2.getListner().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), + consumerTag2.getListener().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag1.getListner().getAllMsgBody())) + consumerTag1.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getAllTagMessageBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerTag2.getListner().getAllMsgBody())) + consumerTag2.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getMessageBodyByTag(tags[0])); } @@ -169,27 +169,27 @@ public class TagMessageWithMulConsumerIT extends BaseConf { producer.send(tagMsgs); Assert.assertEquals("Not all are sent", msgSize * 3, producer.getAllUndupMsgBody().size()); - consumerSubTwoMatchAll.getListner() + consumerSubTwoMatchAll.getListener() .waitForMessageConsume(tagMessage.getMessageBodyByTag(tags), consumeTime); - consumerSubTwoMachieOne.getListner() + consumerSubTwoMachieOne.getListener() .waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), consumeTime); - consumerSubTag1.getListner().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), + consumerSubTag1.getListener().waitForMessageConsume(tagMessage.getMessageBodyByTag(tags[0]), consumeTime); - consumerSubAll.getListner().waitForMessageConsume( + consumerSubAll.getListener().waitForMessageConsume( MQMessageFactory.getMessage(msgsWithNoTag, tagMessage.getAllTagMessageBody()), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerSubTwoMatchAll.getListner().getAllMsgBody())) + consumerSubTwoMatchAll.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getAllTagMessageBody()); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerSubTwoMachieOne.getListner().getAllMsgBody())) + consumerSubTwoMachieOne.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getMessageBodyByTag(tags[0])); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerSubTag1.getListner().getAllMsgBody())) + consumerSubTag1.getListener().getAllMsgBody())) .containsExactlyElementsIn(tagMessage.getMessageBodyByTag(tags[0])); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumerSubAll.getListner().getAllMsgBody())) + consumerSubAll.getListener().getAllMsgBody())) .containsExactlyElementsIn(MQMessageFactory.getMessage(msgsWithNoTag, tagMessage.getAllTagMessageBody())); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithSameGroupConsumerIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithSameGroupConsumerIT.java index 135cbec8bd755b115d2c646b64c7da452d25bf82..df8945e37146fd9941f9b2c4f01e85aaf137c16c 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithSameGroupConsumerIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithSameGroupConsumerIT.java @@ -61,10 +61,10 @@ public class TagMessageWithSameGroupConsumerIT extends BaseConf { new RMQNormalListner(originMsgDCName, msgBodyDCName)); producer.send(tag, msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -82,9 +82,9 @@ public class TagMessageWithSameGroupConsumerIT extends BaseConf { new RMQNormalListner(originMsgDCName, msgBodyDCName)); TestUtils.waitForMoment(5); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -105,9 +105,9 @@ public class TagMessageWithSameGroupConsumerIT extends BaseConf { mqClients.remove(1); TestUtils.waitForMoment(5); - consumer1.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer1.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllMsgBody())) + consumer1.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/MulConsumerMulTopicIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/MulConsumerMulTopicIT.java index 98d858b6a4134c6d606b31b63851421c670fbd6f..56d49afd4d44a835e1ea9923c7f92d21e9279e7c 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/MulConsumerMulTopicIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/MulConsumerMulTopicIT.java @@ -59,7 +59,7 @@ public class MulConsumerMulTopicIT extends BaseConf { Assert.assertEquals("Not all sent succeeded", msgSize * 2, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } @@ -80,7 +80,7 @@ public class MulConsumerMulTopicIT extends BaseConf { Assert.assertEquals("Not all sent succeeded", msgSize * 2, producer.getAllUndupMsgBody().size()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } @@ -102,7 +102,7 @@ public class MulConsumerMulTopicIT extends BaseConf { producer.send(MQMessageFactory.getMsg(topic2, msgSize, tag1)); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/OneConsumerMulTopicIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/OneConsumerMulTopicIT.java index 969fa79da2d387dc9a543239ed75a901ac21d63a..8c1a2841f70b1718b27878795e8a319db3fe6cf7 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/OneConsumerMulTopicIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/OneConsumerMulTopicIT.java @@ -55,9 +55,9 @@ public class OneConsumerMulTopicIT extends BaseConf { producer.send(MQMessageFactory.getMsg(topic2, msgSize)); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -74,9 +74,9 @@ public class OneConsumerMulTopicIT extends BaseConf { producer.send(MQMessageFactory.getMsg(topic2, msgSize, tag)); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } @@ -96,9 +96,9 @@ public class OneConsumerMulTopicIT extends BaseConf { producer.send(MQMessageFactory.getMsg(topic2, msgSize, tag1)); Assert.assertEquals("Not all are sent", msgSize * 2, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java index 24a75473ad9454272397d1182a869bc3b1611db3..637774e2239acfeabcb6909286ab44b9ef31f942 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java @@ -59,12 +59,12 @@ public class AsyncSendWithMessageQueueIT extends BaseConf { producer.waitForResponse(10 * 1000); assertThat(producer.getSuccessMsgCount()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); producer.clearMsg(); consumer.clearMsg(); @@ -74,11 +74,11 @@ public class AsyncSendWithMessageQueueIT extends BaseConf { producer.waitForResponse(10 * 1000); assertThat(producer.getSuccessMsgCount()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java index 82012eabc9f050b7b9d7012ee207eda5f67f612f..12df96787534a9d63c61d83c322cc39d62950ad6 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java @@ -71,12 +71,12 @@ public class AsyncSendWithMessageQueueSelectorIT extends BaseConf { producer.waitForResponse(5 * 1000); assertThat(producer.getSuccessMsgCount()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); producer.clearMsg(); consumer.clearMsg(); @@ -96,11 +96,11 @@ public class AsyncSendWithMessageQueueSelectorIT extends BaseConf { producer.waitForResponse(5 * 1000); assertThat(producer.getSuccessMsgCount()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithOnlySendCallBackIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithOnlySendCallBackIT.java index 51aeef46e36da6714d9255af1b9c4befa83cbccb..7b0d9fdb3eba3806ae269a6b5c2f352d73b05914 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithOnlySendCallBackIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithOnlySendCallBackIT.java @@ -55,9 +55,9 @@ public class AsyncSendWithOnlySendCallBackIT extends BaseConf { producer.waitForResponse(10 * 1000); assertThat(producer.getSuccessMsgCount()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/exception/msg/MessageUserPropIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/exception/msg/MessageUserPropIT.java index b5882df22183067604e1475576c729f8dace098c..b264ef73875912442f77959ef8f47523517d4273 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/exception/msg/MessageUserPropIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/exception/msg/MessageUserPropIT.java @@ -63,10 +63,10 @@ public class MessageUserPropIT extends BaseConf { producer.send(msg, null); assertThat(producer.getAllMsgBody().size()).isEqualTo(1); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); Message sendMsg = (Message) producer.getFirstMsg(); - Message recvMsg = (Message) consumer.getListner().getFirstMsg(); + Message recvMsg = (Message) consumer.getListener().getFirstMsg(); assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey)); } @@ -85,10 +85,10 @@ public class MessageUserPropIT extends BaseConf { producer.send(msg, null); assertThat(producer.getAllMsgBody().size()).isEqualTo(1); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); Message sendMsg = (Message) producer.getFirstMsg(); - Message recvMsg = (Message) consumer.getListner().getFirstMsg(); + Message recvMsg = (Message) consumer.getListener().getFirstMsg(); assertThat(recvMsg.getUserProperty(msgKey)).isEqualTo(sendMsg.getUserProperty(msgKey)); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendIT.java index 37df4f8d41e7d894fe47afe4d367149719cbd1f0..17572dd9631a2efc2262b0c9a155f34a07e44296 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendIT.java @@ -56,9 +56,9 @@ public class OneWaySendIT extends BaseConf { producer.waitForResponse(5 * 1000); assertThat(producer.getAllMsgBody().size()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithMQIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithMQIT.java index a2b601b179f4abcc2045ba64e13adec45c4dc9a5..bfb45a80c52293046dd24d43e231fd656dcc2b5b 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithMQIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithMQIT.java @@ -59,9 +59,9 @@ public class OneWaySendWithMQIT extends BaseConf { producer.sendOneWay(msgSize, mq); producer.waitForResponse(5 * 1000); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); producer.clearMsg(); @@ -71,9 +71,9 @@ public class OneWaySendWithMQIT extends BaseConf { producer.asyncSend(msgSize, mq); producer.waitForResponse(5 * 1000); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithSelectorIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithSelectorIT.java index aa70556a60bbd3783b7fbf77b370ccedbbf6764a..5dd3e4471b26a43886def76e7cc918694c0b4f95 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithSelectorIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithSelectorIT.java @@ -71,12 +71,12 @@ public class OneWaySendWithSelectorIT extends BaseConf { }); assertThat(producer.getAllMsgBody().size()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); producer.clearMsg(); consumer.clearMsg(); @@ -94,11 +94,11 @@ public class OneWaySendWithSelectorIT extends BaseConf { }); assertThat(producer.getAllMsgBody().size()).isEqualTo(msgSize); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); - VerifyUtils.verifyMessageQueueId(queueId, consumer.getListner().getAllOriginMsg()); + VerifyUtils.verifyMessageQueueId(queueId, consumer.getListener().getAllOriginMsg()); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgDynamicRebalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgDynamicRebalanceIT.java index a6520b438d4fc080a0f8d1d30674f48669d58e56..8ae936bd3f65fbc85b10b35bcdcc4bdb2f013e68 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgDynamicRebalanceIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgDynamicRebalanceIT.java @@ -63,20 +63,20 @@ public class OrderMsgDynamicRebalanceIT extends BaseConf { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - MQWait.waitConsumeAll(30 * 1000, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner()); + MQWait.waitConsumeAll(30 * 1000, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener()); consumer2.shutdown(); mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); } @@ -94,22 +94,22 @@ public class OrderMsgDynamicRebalanceIT extends BaseConf { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListner(), - consumer2.getListner(), consumer3.getListner()); + MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), consumer1.getListener(), + consumer2.getListener(), consumer3.getListener()); consumer3.shutdown(); mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(30 * 1000, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener()); assertThat(recvAll).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer3.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer3.getListener()).getMsgs())) .isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgIT.java index 006aaa1536417290bfcf48cbcc97bccd4160e2f9..4b54fedaf88205829265da93597d194afb0294be 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgIT.java @@ -59,13 +59,13 @@ public class OrderMsgIT extends BaseConf { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } @@ -77,13 +77,13 @@ public class OrderMsgIT extends BaseConf { msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } @@ -96,13 +96,13 @@ public class OrderMsgIT extends BaseConf { msgSize); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgRebalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgRebalanceIT.java index 57b69d2e453748d344d77a81c098d8941fa7fa6d..68a207c292a27dc88e0047e6e6bea2c2541d7ded 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgRebalanceIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgRebalanceIT.java @@ -64,19 +64,19 @@ public class OrderMsgRebalanceIT extends BaseConf { producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils.verifyBalance(producer.getAllMsgBody().size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()).size(), + consumer1.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size()); + consumer2.getListener().getAllUndupMsgBody()).size()); assertThat(balance).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); } @@ -97,36 +97,36 @@ public class OrderMsgRebalanceIT extends BaseConf { producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner(), consumer3.getListner(), - consumer4.getListner()); + consumer1.getListener(), consumer2.getListener(), consumer3.getListener(), + consumer4.getListener()); assertThat(recvAll).isEqualTo(true); boolean balance = VerifyUtils .verifyBalance(producer.getAllMsgBody().size(), VerifyUtils .getFilterdMessage(producer.getAllMsgBody(), - consumer1.getListner().getAllUndupMsgBody()) + consumer1.getListener().getAllUndupMsgBody()) .size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer2.getListner().getAllUndupMsgBody()).size(), + consumer2.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer3.getListner().getAllUndupMsgBody()).size(), + consumer3.getListener().getAllUndupMsgBody()).size(), VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer4.getListner().getAllUndupMsgBody()).size()); + consumer4.getListener().getAllUndupMsgBody()).size()); logger.info(String.format("consumer1:%s;consumer2:%s;consumer3:%s,consumer4:%s", - consumer1.getListner().getAllMsgBody().size(), - consumer2.getListner().getAllMsgBody().size(), - consumer3.getListner().getAllMsgBody().size(), - consumer4.getListner().getAllMsgBody().size())); + consumer1.getListener().getAllMsgBody().size(), + consumer2.getListener().getAllMsgBody().size(), + consumer3.getListener().getAllMsgBody().size(), + consumer4.getListener().getAllMsgBody().size())); assertThat(balance).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer3.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer3.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer4.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer4.getListener()).getMsgs())) .isEqualTo(true); } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgWithTagIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgWithTagIT.java index 7db77de4b3bdde3d0cb4e161dae115117d8119f4..0636d58affbd097ff2ba51629c8a192ff8ea2074 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgWithTagIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgWithTagIT.java @@ -60,13 +60,13 @@ public class OrderMsgWithTagIT extends BaseConf { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize, tag); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } @@ -80,13 +80,13 @@ public class OrderMsgWithTagIT extends BaseConf { MessageQueueMsg mqMsgs = new MessageQueueMsg(mqs, msgSize, tag); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } @@ -106,13 +106,13 @@ public class OrderMsgWithTagIT extends BaseConf { mqMsgs = new MessageQueueMsg(mqs, msgSize, tag1); producer.send(mqMsgs.getMsgsWithMQ()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(mqMsgs.getMsgBodys()); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } @@ -134,12 +134,12 @@ public class OrderMsgWithTagIT extends BaseConf { producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer1.getListner(), consumer2.getListner()); + consumer1.getListener(), consumer2.getListener()); assertThat(recvAll).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer1.getListener()).getMsgs())) .isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer2.getListener()).getMsgs())) .isEqualTo(true); } @@ -160,10 +160,10 @@ public class OrderMsgWithTagIT extends BaseConf { producer.send(mqMsgs.getMsgsWithMQ()); boolean recvAll = MQWait.waitConsumeAll(consumeTime, producer.getAllMsgBody(), - consumer.getListner()); + consumer.getListener()); assertThat(recvAll).isEqualTo(true); - assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListner()).getMsgs())) + assertThat(VerifyUtils.verifyOrder(((RMQOrderListener) consumer.getListener()).getMsgs())) .isEqualTo(true); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/querymsg/QueryMsgByIdIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/querymsg/QueryMsgByIdIT.java index 2cdd66c9923d33af5e9a358f578778bdd3b71dc3..2d9bac72a833bc2bae91c3f753ecde2b7e5863ac 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/querymsg/QueryMsgByIdIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/querymsg/QueryMsgByIdIT.java @@ -57,11 +57,11 @@ public class QueryMsgByIdIT extends BaseConf { int msgSize = 20; producer.send(msgSize); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); Assert.assertEquals("Not all are consumed", 0, VerifyUtils.verify(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); - MessageExt recvMsg = (MessageExt) consumer.getListner().getFirstMsg(); + MessageExt recvMsg = (MessageExt) consumer.getListener().getFirstMsg(); MessageExt queryMsg = null; try { TestUtils.waitForMoment(3000); 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 index dc5f230253ab3e551421033b42108e1d3c7adc0f..9b18d5ccefc7a3535f97476817692e88a742c9ef 100644 --- a/test/src/test/java/org/apache/rocketmq/test/delay/NormalMsgDelayIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/delay/NormalMsgDelayIT.java @@ -57,12 +57,12 @@ public class NormalMsgDelayIT extends DelayConf { producer.send(delayMsgs); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); Assert.assertEquals("Not all are consumed", 0, VerifyUtils.verify(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); Assert.assertEquals("Timer is not correct", true, VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000, - ((RMQDelayListner) consumer.getListner()).getMsgDelayTimes())); + ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes())); } @Test @@ -72,13 +72,13 @@ public class NormalMsgDelayIT extends DelayConf { producer.send(delayMsgs); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), DELAY_LEVEL[delayLevel - 1] * 1000 * 2); Assert.assertEquals("Not all are consumed", 0, VerifyUtils.verify(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); Assert.assertEquals("Timer is not correct", true, VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000, - ((RMQDelayListner) consumer.getListner()).getMsgDelayTimes())); + ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes())); } @Test @@ -88,13 +88,13 @@ public class NormalMsgDelayIT extends DelayConf { producer.send(delayMsgs); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), DELAY_LEVEL[delayLevel - 1] * 1000 * 2); Assert.assertEquals("Not all are consumed", 0, VerifyUtils.verify(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); Assert.assertEquals("Timer is not correct", true, VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000, - ((RMQDelayListner) consumer.getListner()).getMsgDelayTimes())); + ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes())); } @Test @@ -104,12 +104,12 @@ public class NormalMsgDelayIT extends DelayConf { producer.send(delayMsgs); Assert.assertEquals("Not all are sent", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), DELAY_LEVEL[delayLevel - 1] * 1000 * 2); Assert.assertEquals("Not all are consumed", 0, VerifyUtils.verify(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())); + consumer.getListener().getAllMsgBody())); Assert.assertEquals("Timer is not correct", true, VerifyUtils.verifyDelay(DELAY_LEVEL[delayLevel - 1] * 1000, - ((RMQDelayListner) consumer.getListner()).getMsgDelayTimes())); + ((RMQDelayListner) consumer.getListener()).getMsgDelayTimes())); } } diff --git a/test/src/test/java/org/apache/rocketmq/test/smoke/NormalMessageSendAndRecvIT.java b/test/src/test/java/org/apache/rocketmq/test/smoke/NormalMessageSendAndRecvIT.java index c4225018143c9af6911bd156e5314db7e3f87fba..35d91717ecb8c98e82b873dba7d92a459ef98ec3 100644 --- a/test/src/test/java/org/apache/rocketmq/test/smoke/NormalMessageSendAndRecvIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/smoke/NormalMessageSendAndRecvIT.java @@ -54,9 +54,9 @@ public class NormalMessageSendAndRecvIT extends BaseConf { int msgSize = 10; producer.send(msgSize); Assert.assertEquals("Not all sent succeeded", msgSize, producer.getAllUndupMsgBody().size()); - consumer.getListner().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); + consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), consumeTime); assertThat(VerifyUtils.getFilterdMessage(producer.getAllMsgBody(), - consumer.getListner().getAllMsgBody())) + consumer.getListener().getAllMsgBody())) .containsExactlyElementsIn(producer.getAllMsgBody()); } }