Fix Java version check

acogoluegnes · acogoluegnes · commit eb89b1f46542 · 2024-11-07T10:53:32.000+01:00
diff --git a/src/main/java/com/rabbitmq/stream/impl/ConcurrencyUtils.java b/src/main/java/com/rabbitmq/stream/impl/ConcurrencyUtils.java
@@ -55,6 +55,7 @@ static ThreadFactory defaultThreadFactory() {
   }
 
   private static boolean isJava21OrMore() {
-    return Utils.versionCompare(System.getProperty("java.version"), "21.0") >= 0;
+    String version = System.getProperty("java.version").replace("-beta", "");
+    return Utils.versionCompare(version, "21.0") >= 0;
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -55,6 +55,7 @@ static ThreadFactory defaultThreadFactory() {`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`private static boolean isJava21OrMore() {`
`58`		`- return Utils.versionCompare(System.getProperty("java.version"), "21.0") >= 0;`
	`58`	`+ String version = System.getProperty("java.version").replace("-beta", "");`
	`59`	`+ return Utils.versionCompare(version, "21.0") >= 0;`
`59`	`60`	`}`
`60`	`61`	`}`