Package br.com.anteros.mqtt.core.server.session

Class InMemoryMqttSessionManager

java.lang.Object

br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager

All Implemented Interfaces:

IMqttSessionManager

public class InMemoryMqttSessionManager
extends Object
implements IMqttSessionManager

内存 session 管理

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
InMemoryMqttSessionManager()

Method Summary

Modifier and Type	Method	Description
boolean	active(String clientId)	激活 session，标记 expire 的 session 为永久
void	addPendingPublish(String clientId, int messageId, MqttPendingPublish pendingPublish)	添加发布过程存储
void	addPendingQos2Publish(String clientId, int messageId, MqttPendingQos2Publish pendingQos2Publish)	添加发布过程存储
void	addSubscribe(String topicFilter, String clientId, int mqttQoS)	添加订阅存储
void	clean()	清理
boolean	expire(String clientId, int sessionExpirySeconds)	标记 session 超时时间
int	getMessageId(String clientId)	生成消息 Id
MqttPendingPublish	getPendingPublish(String clientId, int messageId)	获取发布过程存储
MqttPendingQos2Publish	getPendingQos2Publish(String clientId, int messageId)	获取发布过程存储
boolean	hasSession(String clientId)	判断是否存在 session
void	remove(String clientId)	清除 session
void	removePendingPublish(String clientId, int messageId)	删除发布过程中的存储
void	removePendingQos2Publish(String clientId, int messageId)	删除发布过程中的存储
void	removeSubscribe(String clientId)
void	removeSubscribe(String topicFilter, String clientId)	删除订阅
List<br.com.anteros.mqtt.core.server.model.Subscribe>	searchSubscribe(String topicName)	查找订阅信息
Integer	searchSubscribe(String topicName, String clientId)	查找订阅 qos 信息

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InMemoryMqttSessionManager

public InMemoryMqttSessionManager()

Method Detail

addSubscribe

public void addSubscribe(String topicFilter,
                         String clientId,
                         int mqttQoS)

Description copied from interface: IMqttSessionManager

添加订阅存储

Specified by:

addSubscribe in interface IMqttSessionManager

Parameters:

topicFilter - topicFilter

clientId - 客户端 Id

mqttQoS - MqttQoS

removeSubscribe

public void removeSubscribe(String topicFilter,
                            String clientId)

Description copied from interface: IMqttSessionManager

删除订阅

Specified by:

removeSubscribe in interface IMqttSessionManager

Parameters:

topicFilter - topicFilter

clientId - 客户端 Id

removeSubscribe

public void removeSubscribe(String clientId)

searchSubscribe

public Integer searchSubscribe(String topicName,
                               String clientId)

Description copied from interface: IMqttSessionManager

查找订阅 qos 信息

Specified by:

searchSubscribe in interface IMqttSessionManager

Parameters:

topicName - topicName

clientId - 客户端 Id

Returns:

订阅存储列表

searchSubscribe

public List<br.com.anteros.mqtt.core.server.model.Subscribe> searchSubscribe(String topicName)

Description copied from interface: IMqttSessionManager

查找订阅信息

Specified by:

searchSubscribe in interface IMqttSessionManager

Parameters:

topicName - topicName

Returns:

订阅存储列表

addPendingPublish

public void addPendingPublish(String clientId,
                              int messageId,
                              MqttPendingPublish pendingPublish)

Description copied from interface: IMqttSessionManager

添加发布过程存储

Specified by:

addPendingPublish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

pendingPublish - MqttPendingPublish

getPendingPublish

public MqttPendingPublish getPendingPublish(String clientId,
                                            int messageId)

Description copied from interface: IMqttSessionManager

获取发布过程存储

Specified by:

getPendingPublish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

Returns:

MqttPendingPublish

removePendingPublish

public void removePendingPublish(String clientId,
                                 int messageId)

Description copied from interface: IMqttSessionManager

删除发布过程中的存储

Specified by:

removePendingPublish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

addPendingQos2Publish

public void addPendingQos2Publish(String clientId,
                                  int messageId,
                                  MqttPendingQos2Publish pendingQos2Publish)

Description copied from interface: IMqttSessionManager

添加发布过程存储

Specified by:

addPendingQos2Publish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

pendingQos2Publish - MqttPendingQos2Publish

getPendingQos2Publish

public MqttPendingQos2Publish getPendingQos2Publish(String clientId,
                                                    int messageId)

Description copied from interface: IMqttSessionManager

获取发布过程存储

Specified by:

getPendingQos2Publish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

Returns:

MqttPendingQos2Publish

removePendingQos2Publish

public void removePendingQos2Publish(String clientId,
                                     int messageId)

Description copied from interface: IMqttSessionManager

删除发布过程中的存储

Specified by:

removePendingQos2Publish in interface IMqttSessionManager

Parameters:

clientId - clientId

messageId - messageId

getMessageId

public int getMessageId(String clientId)

Description copied from interface: IMqttSessionManager

生成消息 Id

Specified by:

getMessageId in interface IMqttSessionManager

Parameters:

clientId - clientId

Returns:

messageId

hasSession

public boolean hasSession(String clientId)

Description copied from interface: IMqttSessionManager

判断是否存在 session

Specified by:

hasSession in interface IMqttSessionManager

Parameters:

clientId - clientId

Returns:

是否存在 session

expire

public boolean expire(String clientId,
                      int sessionExpirySeconds)

Description copied from interface: IMqttSessionManager

标记 session 超时时间

Specified by:

expire in interface IMqttSessionManager

Parameters:

clientId - clientId

sessionExpirySeconds - sessionExpirySeconds

Returns:

是否成功

active

public boolean active(String clientId)

Description copied from interface: IMqttSessionManager

激活 session，标记 expire 的 session 为永久

Specified by:

active in interface IMqttSessionManager

Parameters:

clientId - clientId

Returns:

是否成功

remove

public void remove(String clientId)

Description copied from interface: IMqttSessionManager

清除 session

Specified by:

remove in interface IMqttSessionManager

Parameters:

clientId - clientId

clean

public void clean()

Description copied from interface: IMqttSessionManager

清理

Specified by:

clean in interface IMqttSessionManager