Repository: incubator-rocketmq Updated Branches: refs/heads/develop c4a3e0c13 -> f619e451f
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgDynamicRebalanceIT.java ---------------------------------------------------------------------- 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 a6520b4..8ae936b 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgIT.java ---------------------------------------------------------------------- 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 006aaa1..4b54fed 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgRebalanceIT.java ---------------------------------------------------------------------- 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 57b69d2..68a207c 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); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/order/OrderMsgWithTagIT.java ---------------------------------------------------------------------- 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 7db77de..0636d58 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); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/client/producer/querymsg/QueryMsgByIdIT.java ---------------------------------------------------------------------- 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 2cdd66c..2d9bac7 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); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/delay/NormalMsgDelayIT.java ---------------------------------------------------------------------- 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 dc5f230..9b18d5c 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())); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/f619e451/test/src/test/java/org/apache/rocketmq/test/smoke/NormalMessageSendAndRecvIT.java ---------------------------------------------------------------------- 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 c422501..35d9171 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()); } }
