You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2021/12/11 06:07:14 UTC
[rocketmq] branch develop updated: [ISSUE #3624]DefaultMQPushConsumerTest.testPullMessage_ExceptionOccursWhenComputePullFromWhere throws RejectedExecution (#3626)
This is an automated email from the ASF dual-hosted git repository.
yuzhou 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 3a5cdfa [ISSUE #3624]DefaultMQPushConsumerTest.testPullMessage_ExceptionOccursWhenComputePullFromWhere throws RejectedExecution (#3626)
3a5cdfa is described below
commit 3a5cdfa59a4674b8e742433f096a07c280b8c9c3
Author: panzhi <pa...@qq.com>
AuthorDate: Sat Dec 11 14:06:54 2021 +0800
[ISSUE #3624]DefaultMQPushConsumerTest.testPullMessage_ExceptionOccursWhenComputePullFromWhere throws RejectedExecution (#3626)
---
.../rocketmq/client/consumer/DefaultMQPushConsumerTest.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java
index 6c84635..df87932 100644
--- a/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java
+++ b/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java
@@ -57,7 +57,7 @@ import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.common.protocol.header.PullMessageRequestHeader;
import org.apache.rocketmq.remoting.RPCHook;
import org.apache.rocketmq.remoting.exception.RemotingException;
-import org.junit.After;
+import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
@@ -75,7 +75,6 @@ import static org.mockito.ArgumentMatchers.anyLong;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.ArgumentMatchers.nullable;
import static org.mockito.Mockito.doReturn;
-import static org.mockito.Mockito.doThrow;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.when;
@@ -90,7 +89,7 @@ public class DefaultMQPushConsumerTest {
private MQClientAPIImpl mQClientAPIImpl;
private RebalanceImpl rebalanceImpl;
private RebalancePushImpl rebalancePushImpl;
- private DefaultMQPushConsumer pushConsumer;
+ private static DefaultMQPushConsumer pushConsumer;
@Before
public void init() throws Exception {
@@ -157,8 +156,8 @@ public class DefaultMQPushConsumerTest {
pushConsumer.start();
}
- @After
- public void terminate() {
+ @AfterClass
+ public static void terminate() {
pushConsumer.shutdown();
}