提交 c3750b34 编写于 作者: 斜阳

[ISSUE #2708] Reformat

上级 fb34b648
...@@ -214,7 +214,7 @@ public class DefaultMQPushConsumerTest { ...@@ -214,7 +214,7 @@ public class DefaultMQPushConsumerTest {
MessageExt msg = messageAtomic.get(); MessageExt msg = messageAtomic.get();
assertThat(msg).isNotNull(); assertThat(msg).isNotNull();
assertThat(msg.getTopic()).isEqualTo(topic); assertThat(msg.getTopic()).isEqualTo(topic);
assertThat(msg.getBody()).isEqualTo(new byte[]{'a'}); assertThat(msg.getBody()).isEqualTo(new byte[] {'a'});
} }
@Test @Test
...@@ -327,7 +327,6 @@ public class DefaultMQPushConsumerTest { ...@@ -327,7 +327,6 @@ public class DefaultMQPushConsumerTest {
@Test @Test
public void testPullMessage_ExceptionOccursWhenComputePullFromWhere() throws MQClientException { public void testPullMessage_ExceptionOccursWhenComputePullFromWhere() throws MQClientException {
doThrow(MQClientException.class).when(rebalancePushImpl).computePullFromWhereWithException(any(MessageQueue.class));
final CountDownLatch countDownLatch = new CountDownLatch(1); final CountDownLatch countDownLatch = new CountDownLatch(1);
final MessageExt[] messageExts = new MessageExt[1]; final MessageExt[] messageExts = new MessageExt[1];
pushConsumer.getDefaultMQPushConsumerImpl().setConsumeMessageService( pushConsumer.getDefaultMQPushConsumerImpl().setConsumeMessageService(
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册