xy-device/device-api-service/src/main/java/com/xy/consumer/disconnect/DisconnectedMqttConfiguration.java

package com.xy.consumer.disconnect;

import com.xy.configuration.MqttConfigUtils;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.core.MessageProducer;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;

@Configuration
@IntegrationComponentScan
public class DisconnectedMqttConfiguration {

    /**
     * topic
     */
    public final static String TOPIC = "disConnectedNotify";

    /**
     * 入站通道名（消费者）订阅的bean名称
     */
    public static final String CHANNEL_NAME_IN = TOPIC + "MqttInboundChannel";

    /**
     * 出站通道名（生产者）发布的bean名称
     */
    public static final String CHANNEL_NAME_OUT = TOPIC + "MqttOutboundChannel";

    /*******************************生产者*******************************************/

    /**
     * MQTT信息通道（生产者）
     */
    @Bean(name = CHANNEL_NAME_OUT)
    public MessageChannel mqttOutboundChannel() {
        return new DirectChannel();
    }

    /**
     * MQTT消息处理器（生产者）
     */
    @Bean(name = TOPIC + "MqttOutbound")
    @ServiceActivator(inputChannel = CHANNEL_NAME_OUT)
    public MessageHandler mqttOutbound() {
        return MqttConfigUtils.mqttOutbound(TOPIC);
    }


    /*******************************消费者*******************************************/

    /**
     * MQTT信息通道（消费者）
     */
    @Bean(name = CHANNEL_NAME_IN)
    public MessageChannel mqttInboundChannel() {
        return new DirectChannel();
    }

    /**
     * MQTT消息订阅绑定（消费者）
     */
    @Bean(name = TOPIC + "Inbound")
    public MessageProducer inbound() {
        return MqttConfigUtils.inbound(TOPIC, mqttInboundChannel());
    }

    /**
     * MQTT消息处理器（消费者）
     */
    @Bean(name = TOPIC + "Handler")
    @ServiceActivator(inputChannel = CHANNEL_NAME_IN)
    public MessageHandler handler() {
        return MqttConfigUtils.handler();
    }

}