package com.qianwen.mdc.collect.mqtt;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.integration.mqtt.support.MqttHeaders;
|
import org.springframework.messaging.MessageChannel;
|
import org.springframework.messaging.support.MessageBuilder;
|
import org.springframework.stereotype.Service;
|
|
@Service
|
public class MqttMessageSender {
|
@Autowired
|
private MessageChannel mqttOutboundChannel;
|
|
public void sendMessage(String topic, String payload) {
|
mqttOutboundChannel.send(MessageBuilder.withPayload(payload)
|
.setHeader(MqttHeaders.TOPIC, topic)
|
.build());
|
|
}
|
}
|
