package com.dji.sdk.mqtt;

import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

/**
 *
 * @author sean.zhou
 * @date 2021/11/10
 * @version 0.1
 */
public interface IMqttTopicService {

    /**
     * Subscribe to a specific topic.
     * @param topics target
     */
    void subscribe(@Header(MqttHeaders.TOPIC) String... topics);

    /**
     * Subscribe to a specific topic using a specific qos.
     * @param topic target
     * @param qos   qos
     */
    void subscribe(@Header(MqttHeaders.TOPIC) String topic, int qos);

    /**
     * Unsubscribe from a specific topic.
     * @param topics target
     */
    void unsubscribe(@Header(MqttHeaders.TOPIC) String... topics);

    /**
     * Get all the subscribed topics.
     * @return topics
     */
    String[] getSubscribedTopic();
}