package com.tievd.jyz.config.mqtt;
|
|
import org.springframework.integration.annotation.MessagingGateway;
|
import org.springframework.integration.mqtt.support.MqttHeaders;
|
import org.springframework.messaging.handler.annotation.Header;
|
|
/**
|
* 发送网关
|
* @author timi
|
*/
|
@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")
|
public interface MqttGateway {
|
/**
|
* 发送消息
|
*
|
* @param data 发送内容
|
* @param topic 主题
|
*/
|
void sendToMqtt(String data, @Header(MqttHeaders.TOPIC) String topic);
|
}
|
