package com.dji.sample.component.mqtt.service;
|
|
import com.dji.sample.component.mqtt.model.ChannelName;
|
import org.springframework.integration.annotation.MessagingGateway;
|
import org.springframework.integration.mqtt.support.MqttHeaders;
|
import org.springframework.messaging.handler.annotation.Header;
|
import org.springframework.stereotype.Component;
|
|
/**
|
*
|
* @author sean.zhou
|
* @date 2021/11/10
|
* @version 0.1
|
*/
|
@Component
|
@MessagingGateway(defaultRequestChannel = ChannelName.OUTBOUND)
|
public interface IMqttMessageGateway {
|
|
/**
|
* Publish a message to a specific topic.
|
* @param topic target
|
* @param payload message
|
*/
|
void publish(@Header(MqttHeaders.TOPIC) String topic, byte[] payload);
|
|
/**
|
* Use a specific qos to push messages to a specific topic.
|
* @param topic target
|
* @param payload message
|
* @param qos qos
|
*/
|
void publish(@Header(MqttHeaders.TOPIC) String topic, byte[] payload, @Header(MqttHeaders.QOS) int qos);
|
}
|
