You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2019/03/07 11:12:05 UTC
[rocketmq] branch develop updated:
[RIP-10]ConsumeMessageConcurrentlyServiceTest maybe effect other case,
Ignore part test function
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 06eeaed [RIP-10]ConsumeMessageConcurrentlyServiceTest maybe effect other case,Ignore part test function
06eeaed is described below
commit 06eeaed151d1e263d60ce59a17f7ac4d06de0b32
Author: hdchen <14...@qq.com>
AuthorDate: Thu Mar 7 19:11:54 2019 +0800
[RIP-10]ConsumeMessageConcurrentlyServiceTest maybe effect other case,Ignore part test function
---
.../client/impl/consumer/ConsumeMessageConcurrentlyServiceTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyServiceTest.java b/client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyServiceTest.java
index 15a261f..921743c 100644
--- a/client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyServiceTest.java
+++ b/client/src/test/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyServiceTest.java
@@ -36,6 +36,7 @@ import org.apache.rocketmq.common.stats.StatsItemSet;
import org.apache.rocketmq.remoting.exception.RemotingException;
import org.junit.After;
import org.junit.Before;
+import org.junit.Ignore;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mock;
@@ -140,6 +141,7 @@ public class ConsumeMessageConcurrentlyServiceTest {
pushConsumer.getDefaultMQPushConsumerImpl().updateTopicSubscribeInfo(topic, messageQueueSet);
}
+ @Ignore
@Test
public void testPullMessage_ConsumeSuccess() throws InterruptedException, RemotingException, MQBrokerException, NoSuchFieldException,Exception {
final CountDownLatch countDownLatch = new CountDownLatch(1);