提交 7577f24f 编写于 作者: 如梦技术's avatar 如梦技术 🐛

优化 javadoc

上级 78421657
......@@ -96,6 +96,7 @@ public enum TopicFilterType {
/**
* 读取共享订阅的分组名
*
* @param topicFilter topicFilter
* @return 共享订阅分组名
*/
public static String getShareGroupName(String topicFilter) {
......
......@@ -291,6 +291,8 @@ public final class MqttServer {
*
* @param topic topic
* @param message Message
*
* @return 是否成功
*/
public boolean sendToClient(String topic, Message message) {
// 客户端id
......
......@@ -29,6 +29,7 @@ public interface AckService {
* @param command command
* @param maxRetryCount 最大重试次数
* @param retryIntervalSecs 重试间隔
* @return AckTimerTask
*/
AckTimerTask addTask(Runnable command, int maxRetryCount, int retryIntervalSecs);
......
......@@ -148,6 +148,9 @@ public class TimingWheel {
/**
* 添加任务到时间轮
*
* @param timerTaskEntry TimerTaskEntry
* @return 是否成功
*/
public boolean add(TimerTaskEntry timerTaskEntry) {
long expiration = timerTaskEntry.getExpirationMs();
......@@ -183,6 +186,8 @@ public class TimingWheel {
/**
* 推进时间
*
* @param timeMs ms
*/
public void advanceClock(Long timeMs) {
if (timeMs >= currentTime + tickMs) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册