Nitpick from jee-10 branch

Author: Luqman Saeed

src/main/java/fish/payara/trader/aeron/AeronSubscriberBean.java

@@ -18,6 +18,7 @@
 import org.agrona.CloseHelper;
 import org.agrona.concurrent.BackoffIdleStrategy;
 import org.agrona.concurrent.IdleStrategy;
+import org.eclipse.microprofile.config.inject.ConfigProperty;
 
 /**
  * Aeron Ingress Singleton Bean Launches an embedded MediaDriver and subscribes to market data
@@ -43,11 +44,20 @@ public class AeronSubscriberBean {
 
   @Inject @VirtualThreadExecutor private ManagedExecutorService managedExecutorService;
 
+  @Inject
+  @ConfigProperty(name = "TRADER_INGESTION_MODE", defaultValue = "AERON")
+  private String ingestionMode;
+
   void contextInitialized(@Observes @Initialized(ApplicationScoped.class) Object event) {
-    managedExecutorService.submit(() -> init());
+    managedExecutorService.submit(this::init);
   }
 
   public void init() {
+    if ("DIRECT".equalsIgnoreCase(ingestionMode)) {
+      LOGGER.info("Running in DIRECT mode - Skipping Aeron/MediaDriver initialization.");
+      return;
+    }
+
     LOGGER.info("Initializing Aeron Subscriber Bean...");
 
     try {

src/main/java/fish/payara/trader/aeron/MarketDataPublisher.java

@@ -54,8 +54,7 @@ public class MarketDataPublisher {
   private final MarketDepthEncoder marketDepthEncoder = new MarketDepthEncoder();
   private final HeartbeatEncoder heartbeatEncoder = new HeartbeatEncoder();
 
-  // Buffer for encoding messages
-  private final UnsafeBuffer buffer = new UnsafeBuffer(ByteBuffer.allocateDirect(BUFFER_SIZE));
+  private UnsafeBuffer buffer;
 
   private final AtomicLong sequenceNumber = new AtomicLong(0);
   private final AtomicLong tradeIdGenerator = new AtomicLong(1000);
@@ -139,6 +138,9 @@ public void init() {
       return;
     }
 
+    // Initialize buffer only if in AERON mode
+    this.buffer = new UnsafeBuffer(ByteBuffer.allocateDirect(BUFFER_SIZE));
+
     try {
       // Wait for AeronSubscriberBean to be ready (both observers fire at roughly same time)
       LOGGER.info("Waiting for AeronSubscriberBean to be ready...");

src/main/java/fish/payara/trader/rest/GCStatsResource.java

@@ -76,12 +76,12 @@ public Response getComparison() {
     // Identify which JVM is running
     String jvmVendor = System.getProperty("java.vm.vendor");
     String jvmName = System.getProperty("java.vm.name");
+    List<GarbageCollectorMXBean> gcBeans = ManagementFactory.getGarbageCollectorMXBeans();
     String gcName =
-        ManagementFactory.getGarbageCollectorMXBeans().stream()
-            .map(GarbageCollectorMXBean::getName)
-            .collect(Collectors.joining(", "));
+        gcBeans.stream().map(GarbageCollectorMXBean::getName).collect(Collectors.joining(", "));
 
-    boolean isAzulC4 = jvmVendor != null && jvmVendor.contains("Azul");
+    // More accurate check: C4 collector's MXBean is named "GPGC"
+    boolean isAzulC4 = gcBeans.stream().anyMatch(bean -> "GPGC".equals(bean.getName()));
 
     comparison.put("jvmVendor", jvmVendor);
     comparison.put("jvmName", jvmName);
@@ -91,6 +91,9 @@ public Response getComparison() {
 
     // Current stress level
     comparison.put("allocationMode", memoryPressureService.getCurrentMode());
+    comparison.put(
+        "allocationRateMBps",
+        memoryPressureService.getCurrentMode().getBytesPerSecond() / (1024 * 1024));
     comparison.put("messageRate", publisher.getMessagesPublished());
 
     // GC Performance Metrics (keep old stats for backward compatibility)

src/main/java/fish/payara/trader/websocket/MarketDataBroadcaster.java

@@ -2,8 +2,6 @@
 
 import com.hazelcast.core.HazelcastInstance;
 import com.hazelcast.topic.ITopic;
-import com.hazelcast.topic.Message;
-import com.hazelcast.topic.MessageListener;
 import jakarta.annotation.PostConstruct;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
@@ -51,12 +49,9 @@ public void init() {
       if (hazelcastInstance != null) {
         clusterTopic = hazelcastInstance.getTopic(TOPIC_NAME);
         clusterTopic.addMessageListener(
-            new MessageListener<String>() {
-              @Override
-              public void onMessage(Message<String> message) {
-                // Broadcast to local WebSocket sessions only
-                broadcastLocal(message.getMessageObject());
-              }
+            message -> {
+              // Broadcast to local WebSocket sessions only
+              broadcastLocal(message.getMessageObject());
             });
         LOGGER.info("Subscribed to Hazelcast topic: " + TOPIC_NAME + " (clustered mode)");
       } else {