Package br.com.anteros.mqtt.core.client

Class DefaultMqttClientSession

java.lang.Object

br.com.anteros.mqtt.core.client.DefaultMqttClientSession

All Implemented Interfaces:

IMqttClientSession

public final class DefaultMqttClientSession
extends Object
implements IMqttClientSession

客户端 session 管理，包括 sub 和 pub

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
DefaultMqttClientSession()

Method Summary

Modifier and Type	Method	Description
void	addPaddingSubscribe(int messageId, br.com.anteros.mqtt.core.client.MqttPendingSubscription pendingSubscription)	添加订阅
void	addPaddingUnSubscribe(int messageId, br.com.anteros.mqtt.core.client.MqttPendingUnSubscription pendingUnSubscription)	添加取消订阅过程消息
void	addPendingPublish(int messageId, MqttPendingPublish pendingPublish)	添加过程消息
void	addPendingQos2Publish(int messageId, MqttPendingQos2Publish pendingQos2Publish)	添加 qos2 过程消息
void	addSubscriptionList(List<MqttClientSubscription> subscriptionList)	添加订阅
void	clean()	资源清理
List<MqttClientSubscription>	getAndCleanSubscription()	获取并清除订阅
List<MqttClientSubscription>	getMatchedSubscription(String topicName)	获取匹配的订阅
br.com.anteros.mqtt.core.client.MqttPendingSubscription	getPaddingSubscribe(int messageId)	获取过程订阅
br.com.anteros.mqtt.core.client.MqttPendingUnSubscription	getPaddingUnSubscribe(int messageId)	获取取消订阅过程消息
MqttPendingPublish	getPendingPublish(int messageId)	获取过程消息
MqttPendingQos2Publish	getPendingQos2Publish(int messageId)	获取 qos2 过程消息
boolean	isSubscribed(MqttClientSubscription clientSubscription)	判断是否已经订阅过
br.com.anteros.mqtt.core.client.MqttPendingSubscription	removePaddingSubscribe(int messageId)	删除过程订阅
br.com.anteros.mqtt.core.client.MqttPendingUnSubscription	removePaddingUnSubscribe(int messageId)	删除取消订阅过程消息
MqttPendingPublish	removePendingPublish(int messageId)	删除过程消息
MqttPendingQos2Publish	removePendingQos2Publish(int messageId)	删除 qos2 过程消息
void	removeSubscriptions(List<String> topicFilters)	删除订阅过程消息

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMqttClientSession

public DefaultMqttClientSession()

Method Detail

addPaddingSubscribe

public void addPaddingSubscribe(int messageId,
                                br.com.anteros.mqtt.core.client.MqttPendingSubscription pendingSubscription)

Description copied from interface: IMqttClientSession

添加订阅

Specified by:

addPaddingSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

pendingSubscription - MqttPendingSubscription

getPaddingSubscribe

public br.com.anteros.mqtt.core.client.MqttPendingSubscription getPaddingSubscribe(int messageId)

Description copied from interface: IMqttClientSession

获取过程订阅

Specified by:

getPaddingSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingSubscription

removePaddingSubscribe

public br.com.anteros.mqtt.core.client.MqttPendingSubscription removePaddingSubscribe(int messageId)

Description copied from interface: IMqttClientSession

删除过程订阅

Specified by:

removePaddingSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingSubscription

addSubscriptionList

public void addSubscriptionList(List<MqttClientSubscription> subscriptionList)

Description copied from interface: IMqttClientSession

添加订阅

Specified by:

addSubscriptionList in interface IMqttClientSession

Parameters:

subscriptionList - MqttClientSubscription 集合

isSubscribed

public boolean isSubscribed(MqttClientSubscription clientSubscription)

Description copied from interface: IMqttClientSession

判断是否已经订阅过

Specified by:

isSubscribed in interface IMqttClientSession

Parameters:

clientSubscription - MqttClientSubscription

Returns:

是否已经订阅过

getAndCleanSubscription

public List<MqttClientSubscription> getAndCleanSubscription()

Description copied from interface: IMqttClientSession

获取并清除订阅

Specified by:

getAndCleanSubscription in interface IMqttClientSession

Returns:

订阅集合

getMatchedSubscription

public List<MqttClientSubscription> getMatchedSubscription(String topicName)

Description copied from interface: IMqttClientSession

获取匹配的订阅

Specified by:

getMatchedSubscription in interface IMqttClientSession

Parameters:

topicName - topicName

Returns:

订阅信息集合

removeSubscriptions

public void removeSubscriptions(List<String> topicFilters)

Description copied from interface: IMqttClientSession

删除订阅过程消息

Specified by:

removeSubscriptions in interface IMqttClientSession

Parameters:

topicFilters - topicFilter 集合

addPaddingUnSubscribe

public void addPaddingUnSubscribe(int messageId,
                                  br.com.anteros.mqtt.core.client.MqttPendingUnSubscription pendingUnSubscription)

Description copied from interface: IMqttClientSession

添加取消订阅过程消息

Specified by:

addPaddingUnSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

pendingUnSubscription - MqttPendingUnSubscription

getPaddingUnSubscribe

public br.com.anteros.mqtt.core.client.MqttPendingUnSubscription getPaddingUnSubscribe(int messageId)

Description copied from interface: IMqttClientSession

获取取消订阅过程消息

Specified by:

getPaddingUnSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingUnSubscription

removePaddingUnSubscribe

public br.com.anteros.mqtt.core.client.MqttPendingUnSubscription removePaddingUnSubscribe(int messageId)

Description copied from interface: IMqttClientSession

删除取消订阅过程消息

Specified by:

removePaddingUnSubscribe in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingUnSubscription

addPendingPublish

public void addPendingPublish(int messageId,
                              MqttPendingPublish pendingPublish)

Description copied from interface: IMqttClientSession

添加过程消息

Specified by:

addPendingPublish in interface IMqttClientSession

Parameters:

messageId - messageId

pendingPublish - MqttPendingPublish

getPendingPublish

public MqttPendingPublish getPendingPublish(int messageId)

Description copied from interface: IMqttClientSession

获取过程消息

Specified by:

getPendingPublish in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingPublish

removePendingPublish

public MqttPendingPublish removePendingPublish(int messageId)

Description copied from interface: IMqttClientSession

删除过程消息

Specified by:

removePendingPublish in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingPublish

addPendingQos2Publish

public void addPendingQos2Publish(int messageId,
                                  MqttPendingQos2Publish pendingQos2Publish)

Description copied from interface: IMqttClientSession

添加 qos2 过程消息

Specified by:

addPendingQos2Publish in interface IMqttClientSession

Parameters:

messageId - messageId

pendingQos2Publish - MqttPendingQos2Publish

getPendingQos2Publish

public MqttPendingQos2Publish getPendingQos2Publish(int messageId)

Description copied from interface: IMqttClientSession

获取 qos2 过程消息

Specified by:

getPendingQos2Publish in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingQos2Publish

removePendingQos2Publish

public MqttPendingQos2Publish removePendingQos2Publish(int messageId)

Description copied from interface: IMqttClientSession

删除 qos2 过程消息

Specified by:

removePendingQos2Publish in interface IMqttClientSession

Parameters:

messageId - messageId

Returns:

MqttPendingQos2Publish

clean

public void clean()

Description copied from interface: IMqttClientSession

资源清理

Specified by:

clean in interface IMqttClientSession