Fixed typo.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/f619e451 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/f619e451 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/f619e451 Branch: refs/heads/develop Commit: f619e451f948ef6b5b360758867b9ae471499e2e Parents: c4a3e0c Author: shroman <[email protected]> Authored: Thu Jun 15 09:48:10 2017 +0900 Committer: shroman <[email protected]> Committed: Thu Jun 15 09:48:10 2017 +0900 ---------------------------------------------------------------------- .../test/client/rmq/RMQNormalConsumer.java | 12 +++--- .../clientinterface/AbstractMQConsumer.java | 24 ++++++------ .../test/listener/AbstractListener.java | 14 +++---- .../rmq/concurrent/RMQDelayListner.java | 2 +- .../rmq/concurrent/RMQNormalListner.java | 4 +- .../listener/rmq/order/RMQOrderListener.java | 4 +- .../balance/NormalMsgDynamicBalanceIT.java | 20 +++++----- .../balance/NormalMsgStaticBalanceIT.java | 18 ++++----- .../normal/BroadCastNormalMsgNotRecvIT.java | 8 ++-- .../normal/BroadCastNormalMsgRecvCrashIT.java | 12 +++--- .../normal/BroadCastNormalMsgRecvFailIT.java | 4 +- .../BroadCastNormalMsgRecvStartLaterIT.java | 12 +++--- .../BroadCastNormalMsgTwoDiffGroupRecvIT.java | 8 ++-- .../normal/NormalMsgTwoSameGroupConsumerIT.java | 8 ++-- .../broadcast/order/OrderMsgBroadCastIT.java | 8 ++-- .../tag/BroadCastTwoConsumerFilterIT.java | 8 ++-- .../tag/BroadCastTwoConsumerSubDiffTagIT.java | 8 ++-- .../tag/BroadCastTwoConsumerSubTagIT.java | 8 ++-- .../consumer/cluster/DynamicAddAndCrashIT.java | 12 +++--- .../consumer/cluster/DynamicAddConsumerIT.java | 12 +++--- .../cluster/DynamicCrashConsumerIT.java | 12 +++--- .../client/consumer/filter/SqlFilterIT.java | 9 ++--- .../test/client/consumer/tag/MulTagSubIT.java | 18 ++++----- .../consumer/tag/TagMessageWith1ConsumerIT.java | 32 ++++++++-------- .../tag/TagMessageWithMulConsumerIT.java | 40 ++++++++++---------- .../tag/TagMessageWithSameGroupConsumerIT.java | 12 +++--- .../consumer/topic/MulConsumerMulTopicIT.java | 6 +-- .../consumer/topic/OneConsumerMulTopicIT.java | 12 +++--- .../async/AsyncSendWithMessageQueueIT.java | 12 +++--- .../AsyncSendWithMessageQueueSelectorIT.java | 12 +++--- .../async/AsyncSendWithOnlySendCallBackIT.java | 4 +- .../exception/msg/MessageUserPropIT.java | 8 ++-- .../client/producer/oneway/OneWaySendIT.java | 4 +- .../producer/oneway/OneWaySendWithMQIT.java | 8 ++-- .../oneway/OneWaySendWithSelectorIT.java | 12 +++--- .../order/OrderMsgDynamicRebalanceIT.java | 22 +++++------ .../test/client/producer/order/OrderMsgIT.java | 18 ++++----- .../producer/order/OrderMsgRebalanceIT.java | 38 +++++++++---------- .../producer/order/OrderMsgWithTagIT.java | 28 +++++++------- .../producer/querymsg/QueryMsgByIdIT.java | 6 +-- .../rocketmq/test/delay/NormalMsgDelayIT.java | 24 ++++++------ .../test/smoke/NormalMessageSendAndRecvIT.java | 4 +- 42 files changed, 272 insertions(+), 275 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java ---------------------------------------------------------------------- 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 3f185d3..7225cd6 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() { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/clientinterface/AbstractMQConsumer.java ---------------------------------------------------------------------- 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 a077129..22193bb 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(); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java ---------------------------------------------------------------------- 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 14da397..6a13049 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<Object> 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); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQDelayListner.java ---------------------------------------------------------------------- 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 b4a0870..6d9892c 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())); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/listener/rmq/concurrent/RMQNormalListner.java ---------------------------------------------------------------------- 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 471fb48..679f8bd 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())); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/main/java/org/apache/rocketmq/test/listener/rmq/order/RMQOrderListener.java ---------------------------------------------------------------------- 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 91883d8..85c6177 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); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java ---------------------------------------------------------------------- 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 fdafdf0..835f746 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgStaticBalanceIT.java ---------------------------------------------------------------------- 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 117d643..9c9b254 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgNotRecvIT.java ---------------------------------------------------------------------- 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 32b13fd..41408b8 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvCrashIT.java ---------------------------------------------------------------------- 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 b878d09..fc0cfce 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()); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvFailIT.java ---------------------------------------------------------------------- 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 26c37f9..0d3f6fb 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgRecvStartLaterIT.java ---------------------------------------------------------------------- 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 027f648..dd1db0b 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/BroadCastNormalMsgTwoDiffGroupRecvIT.java ---------------------------------------------------------------------- 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 acbaf23..4fb5005 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/NormalMsgTwoSameGroupConsumerIT.java ---------------------------------------------------------------------- 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 984c941..76e69b3 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()); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/OrderMsgBroadCastIT.java ---------------------------------------------------------------------- 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 ac8fcf5..2c9abc0 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerFilterIT.java ---------------------------------------------------------------------- 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 a1a2ff7..0d3b1ca 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubDiffTagIT.java ---------------------------------------------------------------------- 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 5c2e7fc..155a0aa 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/BroadCastTwoConsumerSubTagIT.java ---------------------------------------------------------------------- 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 e4510de..e89464f 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddAndCrashIT.java ---------------------------------------------------------------------- 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 303dfa0..23248e3 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicAddConsumerIT.java ---------------------------------------------------------------------- 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 46dbb70..9ef7953 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/cluster/DynamicCrashConsumerIT.java ---------------------------------------------------------------------- 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 807f950..1323720 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java ---------------------------------------------------------------------- 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 7eef2ab..6c96e5e 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/MulTagSubIT.java ---------------------------------------------------------------------- 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 ecb204e..37ccb4d 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWith1ConsumerIT.java ---------------------------------------------------------------------- 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 f0a1d48..1952f30 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)); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithMulConsumerIT.java ---------------------------------------------------------------------- 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 995bf41..8cc97f2 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())); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/tag/TagMessageWithSameGroupConsumerIT.java ---------------------------------------------------------------------- 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 135cbec..df8945e 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/MulConsumerMulTopicIT.java ---------------------------------------------------------------------- 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 98d858b..56d49af 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/consumer/topic/OneConsumerMulTopicIT.java ---------------------------------------------------------------------- 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 969fa79..8c1a284 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java ---------------------------------------------------------------------- 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 24a7547..637774e 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueSelectorIT.java ---------------------------------------------------------------------- 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 82012ea..12df967 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithOnlySendCallBackIT.java ---------------------------------------------------------------------- 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 51aeef4..7b0d9fd 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()); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/exception/msg/MessageUserPropIT.java ---------------------------------------------------------------------- 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 b5882df..b264ef7 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)); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendIT.java ---------------------------------------------------------------------- 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 37df4f8..17572dd 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithMQIT.java ---------------------------------------------------------------------- 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 a2b601b..bfb45a8 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()); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/oneway/OneWaySendWithSelectorIT.java ---------------------------------------------------------------------- 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 aa70556..5dd3e44 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()); } }
