Compile your Java event handlers to a flat dispatcher you can read.

//DEPS com.telamin.fluxtion:fluxtion-builder:1.0.8
//JAVA 21
package demo;
import com.telamin.fluxtion.Fluxtion;
import com.telamin.fluxtion.runtime.DataFlow;
import com.telamin.fluxtion.runtime.annotations.OnEventHandler;
import com.telamin.fluxtion.runtime.annotations.OnTrigger;
 
public class Trades {
    public static void main(String[] a) {
        // Add only the child — Fluxtion discovers TradeCounter and
        // emits the dispatcher below.
        DataFlow flow = (DataFlow) Fluxtion.compileAot(
                "demo.generated", "TradeProcessor",
                new TradePublisher(new TradeCounter()));
        flow.init();
        flow.onEvent(new Trade("AAPL", 100));
        System.out.println("""
 
                See generated Fluxtion dispatcher here:
                less src/main/java/demo/generated/TradeProcessor.java""");
    }
 
    public record Trade(String symbol, int qty) {}
 
    public static class TradeCounter {
        private int count;
        @OnEventHandler public boolean onTrade(Trade t) {
            count++;
            System.out.println("received -> " + t);
            return true;
        }
        public int count() { return count; }
    }
 
    public static class TradePublisher {
        private final TradeCounter counter;
        public TradePublisher(TradeCounter counter) { this.counter = counter; }
        @OnTrigger public boolean publishCount() {
            System.out.println("trades: " + counter.count());
            return true;
        }
    }
}

// Generated by Fluxtion. This is the file you read,
// audit, diff in your VCS, and ship to production.
 
public final class TradeProcessor implements EventProcessor {
 
    private final TradeCounter   tradeCounter = new TradeCounter();
    private final TradePublisher publisher =
            new TradePublisher(tradeCounter);
 
    @Override
    public void onEvent(Object event) {
        if (event instanceof Trade) {
            handleEvent((Trade) event);
        }
    }
 
    // Strongly-typed dispatch. One method per event type.
    // The dispatcher's structure IS your event graph — every
    // node call, every trigger edge, made explicit.
    private void handleEvent(Trade typedEvent) {
        boolean tradeCounter_updated =
                tradeCounter.onTrade(typedEvent);
 
        // @OnTrigger fan-out, in dependency order.
        if (tradeCounter_updated) {
            publisher.publishCount();
        }
    }
}