silentbalanceyh/vertx-zero

package io.vertx.up;

import io.horizon.runtime.Runner;
import io.horizon.uca.boot.KLauncher;
import io.macrocosm.specification.config.HConfig;
import io.vertx.core.Vertx;
import io.vertx.up.boot.anima.DetectScatter;
import io.vertx.up.boot.anima.InfixScatter;
import io.vertx.up.boot.anima.PointScatter;
import io.vertx.up.boot.anima.Scatter;
import io.vertx.up.runtime.ZeroArcane;
import io.vertx.up.util.Ut;

/**
 * Vertx EmApp begin launcher for api gateway.
 * It's only used in Micro Service mode.
 */
public class MicroApplication {

    public static void run(final Class<?> clazz, final String... args) {
        // 构造启动器容器
        final KLauncher<Vertx> container = KLauncher.create(clazz, args);
        container.start((vertx, config) ->

            ZeroArcane.start(vertx, config, MicroApplication::runComponent));
    }

    private static void runComponent(final Vertx vertx, final HConfig config) {
        /* 1.Find Agent for deploy **/
        Runner.run(() -> {
            final Scatter<Vertx> scatter = Ut.singleton(PointScatter.class);
            scatter.connect(vertx, config);
        }, "component-gateway");
        /* 2.Find Worker for deploy **/
        Runner.run(() -> {
            final Scatter<Vertx> scatter = Ut.singleton(DetectScatter.class);
            scatter.connect(vertx, config);
        }, "component-detect");
        /* 3.Initialize Infusion **/
        Runner.run(() -> {
            // Infusion For Api Gateway
            final Scatter<Vertx> scatter = Ut.singleton(InfixScatter.class);
            scatter.connect(vertx, config);
        }, "component-infix");
    }
}