From b2ebf5361beb98ed210a08e5c2d50e29d72d114d Mon Sep 17 00:00:00 2001 From: 67 <67@gd67.com> Date: Mon, 30 Sep 2024 09:58:40 +0800 Subject: [PATCH] integration test debug style --- .../rocketmq/test/client/producer/batch/BatchSendIT.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java b/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java index 5c1b834fce6..77bdd64e3c7 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/producer/batch/BatchSendIT.java @@ -266,12 +266,12 @@ public void testBatchSend_CompressionBody() throws Exception { Assert.assertEquals(i + startOffset, messageExt.getQueueOffset()); Assert.assertEquals(batchTopic, messageExt.getTopic()); Assert.assertEquals(messageQueue.getQueueId(), messageExt.getQueueId()); - if(bodyLen!=messageExt.getBody().length){ - logger.error("decompress fail? {} {}",i,messageExt); + if (bodyLen != messageExt.getBody().length) { + logger.error("decompress fail? {} {}", i, messageExt); } Assert.assertEquals(bodyLen, messageExt.getBody().length); Assert.assertTrue((messageExt.getSysFlag() & MessageSysFlag.COMPRESSED_FLAG) != 0); - Assert.assertTrue(messageExt.getStoreSize()