erp / mqtt-agent · Files

package com.diligrp.mqtt.vertx.deploy;

import io.vertx.core.Vertx;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

/**
 * @Author: zhangmeiyang
 * @CreateTime: 2025-12-26 17:16
 * @Version: todo
 */
@Component
@Slf4j
public class VerticleDeployer implements CommandLineRunner, DisposableBean {

    private final Vertx vertx;

    public VerticleDeployer(Vertx vertx) {
        this.vertx = vertx;
    }

    @Override
    public void run(String... args) throws Exception {
        vertx.deployVerticle(new MqttVerticle());
        log.info("MqttVerticle deployed");
    }

    @Override
    public void destroy() throws Exception {
        vertx.close();
        log.info("Vertx closed");
    }
}