integration test debug style

apache · Sep 30, 2024 · b2ebf53 · b2ebf53
1 parent f083373
commit b2ebf53
Showing 1 changed file with 3 additions and 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
@@ -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()<bodyLen);
+                Assert.assertTrue(messageExt.getStoreSize() < bodyLen);
             }
         }
     }