| | |
| | | import com.dji.sample.component.mqtt.model.CommonTopicResponse; |
| | | import com.dji.sample.component.mqtt.model.ServiceReply; |
| | | |
| | | import java.util.Optional; |
| | | |
| | | /** |
| | | * @author sean.zhou |
| | | * @version 0.1 |
| | |
| | | * @param response notification of whether the start is successful. |
| | | * @return |
| | | */ |
| | | Optional<ServiceReply> publishWithReply(String topic, CommonTopicResponse response); |
| | | ServiceReply publishWithReply(String topic, CommonTopicResponse response); |
| | | |
| | | /** |
| | | * Send live streaming start message and receive a response at the same time. |
| | |
| | | * @param <T> |
| | | * @return |
| | | */ |
| | | <T> Optional<T> publishWithReply(Class<T> clazz, String topic, CommonTopicResponse response, int retryTime); |
| | | <T> T publishWithReply(Class<T> clazz, String topic, CommonTopicResponse response, int retryTime); |
| | | } |