[AMQ-9394] Annotate Virtual Thread support with @feature

apache · Mar 23, 2024 · 7afc9cf · 7afc9cf
1 parent b5a2595
commit 7afc9cf
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java b/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
@@ -50,6 +50,8 @@
 import org.apache.activemq.ConfigurationException;
 import org.apache.activemq.Service;
 import org.apache.activemq.advisory.AdvisoryBroker;
+import org.apache.activemq.annotation.Feature;
+import org.apache.activemq.annotation.FeatureStatus;
 import org.apache.activemq.broker.cluster.ConnectionSplitBroker;
 import org.apache.activemq.broker.jmx.AnnotatedMBean;
 import org.apache.activemq.broker.jmx.BrokerMBeanSupport;
@@ -1897,6 +1899,7 @@ public boolean isVirtualThreadTaskRunner() {
         return virtualThreadTaskRunner;
     }
 
+    @Feature(description = "Tech Preview for Virtaul Thread support", issueId = "AMQ-9394", status = FeatureStatus.PREVIEW)
     public void setVirtualThreadTaskRunner(boolean virtualThreadTaskRunner) {
         this.virtualThreadTaskRunner = virtualThreadTaskRunner;
     }

diff --git a/activemq-client-jdk21/src/main/java/org/apache/activemq/thread/VirtualThreadExecutor.java b/activemq-client-jdk21/src/main/java/org/apache/activemq/thread/VirtualThreadExecutor.java
@@ -21,8 +21,11 @@
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicLong;
 
+import org.apache.activemq.annotation.Feature;
+import org.apache.activemq.annotation.FeatureStatus;
 import org.slf4j.Logger;
 
+@Feature(description = "Tech Preview for Virtaul Thread support", issueId = "AMQ-9394", status = FeatureStatus.PREVIEW)
 public class VirtualThreadExecutor {
 
     private VirtualThreadExecutor() {}

diff --git a/activemq-client-jdk21/src/main/java/org/apache/activemq/thread/VirtualThreadTaskRunner.java b/activemq-client-jdk21/src/main/java/org/apache/activemq/thread/VirtualThreadTaskRunner.java
@@ -25,9 +25,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- *
- */
 class VirtualThreadTaskRunner implements TaskRunner {
 
     private static final Logger LOG = LoggerFactory.getLogger(VirtualThreadTaskRunner.class);