From c3750b343e80bf86797fb86ed40ae388f5c827ee Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=96=9C=E9=98=B3?= <terrance.lzm@alibaba-inc.com>
Date: Wed, 26 May 2021 11:38:48 +0800
Subject: [PATCH] [ISSUE #2708] Reformat

---
 .../rocketmq/client/consumer/DefaultMQPushConsumerTest.java    | 3 +--
 1 file changed, 1 insertion(+), 2 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 ac69a71f..6c846354 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
@@ -214,7 +214,7 @@ public class DefaultMQPushConsumerTest {
         MessageExt msg = messageAtomic.get();
         assertThat(msg).isNotNull();
         assertThat(msg.getTopic()).isEqualTo(topic);
-        assertThat(msg.getBody()).isEqualTo(new byte[]{'a'});
+        assertThat(msg.getBody()).isEqualTo(new byte[] {'a'});
     }
 
     @Test
@@ -327,7 +327,6 @@ public class DefaultMQPushConsumerTest {
 
     @Test
     public void testPullMessage_ExceptionOccursWhenComputePullFromWhere() throws MQClientException {
-        doThrow(MQClientException.class).when(rebalancePushImpl).computePullFromWhereWithException(any(MessageQueue.class));
         final CountDownLatch countDownLatch = new CountDownLatch(1);
         final MessageExt[] messageExts = new MessageExt[1];
         pushConsumer.getDefaultMQPushConsumerImpl().setConsumeMessageService(
-- 
GitLab