package com.sandu.ximon.admin.manager.iot.amqp;

import lombok.AllArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * @author chenjiantian
 * @date 2021/12/2 17:45
 */
@Component
//@AllArgsConstructor
public class InitAmqpListener {

    @Autowired
    private MqttMainBoardConfig mqttMainBoardConfig;
    @Value("${listenter.isOpen}")
    private boolean isOpen;

    @PostConstruct
    public void initListener() throws Exception {
        if (isOpen) {
            new AmqpClient(
                    mqttMainBoardConfig
            ).execute();
        }
    }
}