This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 606cefeb31 [ISSUE #8514] Fix bazel-compile (ubuntu-latest) ci run
failure (#8515)
606cefeb31 is described below
commit 606cefeb31187f38babea0b786a216a0bc6df238
Author: yx9o <[email protected]>
AuthorDate: Sat Aug 10 21:07:36 2024 +0800
[ISSUE #8514] Fix bazel-compile (ubuntu-latest) ci run failure (#8515)
* [ISSUE #8514] Fix bazel-compile (ubuntu-latest) ci run failure
* Update
* Update
---
.../common/compression/CompressionTypeTest.java | 39 ++++++++++------------
1 file changed, 18 insertions(+), 21 deletions(-)
diff --git
a/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java
b/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java
index e0ec18fd44..f9586bd2da 100644
---
a/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java
+++
b/common/src/test/java/org/apache/rocketmq/common/compression/CompressionTypeTest.java
@@ -17,44 +17,41 @@
package org.apache.rocketmq.common.compression;
import org.apache.rocketmq.common.sysflag.MessageSysFlag;
-import org.junit.jupiter.api.Test;
+import org.junit.Test;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertThrows;
public class CompressionTypeTest {
@Test
public void testCompressionTypeValues() {
- assertEquals(1, CompressionType.LZ4.getValue(), "LZ4 value should be
1");
- assertEquals(2, CompressionType.ZSTD.getValue(), "ZSTD value should be
2");
- assertEquals(3, CompressionType.ZLIB.getValue(), "ZLIB value should be
3");
+ assertEquals(1, CompressionType.LZ4.getValue());
+ assertEquals(2, CompressionType.ZSTD.getValue());
+ assertEquals(3, CompressionType.ZLIB.getValue());
}
@Test
public void testCompressionTypeOf() {
- assertEquals(CompressionType.LZ4, CompressionType.of("LZ4"),
"CompressionType.of(LZ4) should return LZ4");
- assertEquals(CompressionType.ZSTD, CompressionType.of("ZSTD"),
"CompressionType.of(ZSTD) should return ZSTD");
- assertEquals(CompressionType.ZLIB, CompressionType.of("ZLIB"),
"CompressionType.of(ZLIB) should return ZLIB");
-
- assertThrows(RuntimeException.class, () ->
CompressionType.of("UNKNOWN"), "Unsupported compression type should throw
RuntimeException");
+ assertEquals(CompressionType.LZ4, CompressionType.of("LZ4"));
+ assertEquals(CompressionType.ZSTD, CompressionType.of("ZSTD"));
+ assertEquals(CompressionType.ZLIB, CompressionType.of("ZLIB"));
+ assertThrows(RuntimeException.class, () ->
CompressionType.of("UNKNOWN"));
}
@Test
public void testCompressionTypeFindByValue() {
- assertEquals(CompressionType.LZ4, CompressionType.findByValue(1),
"CompressionType.findByValue(1) should return LZ4");
- assertEquals(CompressionType.ZSTD, CompressionType.findByValue(2),
"CompressionType.findByValue(2) should return ZSTD");
- assertEquals(CompressionType.ZLIB, CompressionType.findByValue(3),
"CompressionType.findByValue(3) should return ZLIB");
-
- assertEquals(CompressionType.ZLIB, CompressionType.findByValue(0),
"CompressionType.findByValue(0) should return ZLIB for backward compatibility");
-
- assertThrows(RuntimeException.class, () ->
CompressionType.findByValue(99), "Invalid value should throw RuntimeException");
+ assertEquals(CompressionType.LZ4, CompressionType.findByValue(1));
+ assertEquals(CompressionType.ZSTD, CompressionType.findByValue(2));
+ assertEquals(CompressionType.ZLIB, CompressionType.findByValue(3));
+ assertEquals(CompressionType.ZLIB, CompressionType.findByValue(0));
+ assertThrows(RuntimeException.class, () ->
CompressionType.findByValue(99));
}
@Test
public void testCompressionFlag() {
- assertEquals(MessageSysFlag.COMPRESSION_LZ4_TYPE,
CompressionType.LZ4.getCompressionFlag(), "LZ4 compression flag is incorrect");
- assertEquals(MessageSysFlag.COMPRESSION_ZSTD_TYPE,
CompressionType.ZSTD.getCompressionFlag(), "ZSTD compression flag is
incorrect");
- assertEquals(MessageSysFlag.COMPRESSION_ZLIB_TYPE,
CompressionType.ZLIB.getCompressionFlag(), "ZLIB compression flag is
incorrect");
+ assertEquals(MessageSysFlag.COMPRESSION_LZ4_TYPE,
CompressionType.LZ4.getCompressionFlag());
+ assertEquals(MessageSysFlag.COMPRESSION_ZSTD_TYPE,
CompressionType.ZSTD.getCompressionFlag());
+ assertEquals(MessageSysFlag.COMPRESSION_ZLIB_TYPE,
CompressionType.ZLIB.getCompressionFlag());
}
}