提交 81a5a5cc 编写于 作者: 浅梦2013's avatar 浅梦2013

优化 javadoc。

上级 86ab7ebe
......@@ -49,7 +49,8 @@ public abstract class AbstractMqttMessageDispatcher implements IMqttMessageDispa
/**
* 转发消息到设备,如果 clientId 就在本服务,会自行消化
*
* @param message Message
* @param clientId clientId
* @param message Message
* @return 是否成功
*/
abstract public boolean sendTo(String clientId, Message message);
......
......@@ -67,6 +67,7 @@ public interface IMqttSessionManager {
/**
* 添加发布过程存储
*
* @param clientId clientId
* @param messageId messageId
* @param pendingPublish MqttPendingPublish
*/
......@@ -75,6 +76,7 @@ public interface IMqttSessionManager {
/**
* 获取发布过程存储
*
* @param clientId clientId
* @param messageId messageId
* @return MqttPendingPublish
*/
......@@ -83,6 +85,7 @@ public interface IMqttSessionManager {
/**
* 删除发布过程中的存储
*
* @param clientId clientId
* @param messageId messageId
*/
void removePendingPublish(String clientId, int messageId);
......@@ -90,6 +93,7 @@ public interface IMqttSessionManager {
/**
* 添加发布过程存储
*
* @param clientId clientId
* @param messageId messageId
* @param pendingQos2Publish MqttPendingQos2Publish
*/
......@@ -98,6 +102,7 @@ public interface IMqttSessionManager {
/**
* 获取发布过程存储
*
* @param clientId clientId
* @param messageId messageId
* @return MqttPendingQos2Publish
*/
......@@ -106,6 +111,7 @@ public interface IMqttSessionManager {
/**
* 删除发布过程中的存储
*
* @param clientId clientId
* @param messageId messageId
*/
void removePendingQos2Publish(String clientId, int messageId);
......@@ -113,6 +119,7 @@ public interface IMqttSessionManager {
/**
* 生成消息 Id
*
* @param clientId clientId
* @return messageId
*/
int getMessageId(String clientId);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册