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

Interface IMqttClientSession

  • All Known Implementing Classes:
    DefaultMqttClientSession
    public interface IMqttClientSession
    客户端 session
    Author:
    L.cm

    • Method Detail

      • addPaddingSubscribe

        void addPaddingSubscribe​(int messageId,
                         br.com.anteros.mqtt.core.client.MqttPendingSubscription pendingSubscription)
        添加订阅
        Parameters:
        messageId - messageId
        pendingSubscription - MqttPendingSubscription

      • getPaddingSubscribe

        br.com.anteros.mqtt.core.client.MqttPendingSubscription getPaddingSubscribe​(int messageId)
        获取过程订阅
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingSubscription

      • removePaddingSubscribe

        br.com.anteros.mqtt.core.client.MqttPendingSubscription removePaddingSubscribe​(int messageId)
        删除过程订阅
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingSubscription

      • addSubscriptionList

        void addSubscriptionList​(List<MqttClientSubscription> subscriptionList)
        添加订阅
        Parameters:
        subscriptionList - MqttClientSubscription 集合

      • isSubscribed

        boolean isSubscribed​(MqttClientSubscription clientSubscription)
        判断是否已经订阅过
        Parameters:
        clientSubscription - MqttClientSubscription
        Returns:
        是否已经订阅过

      • getMatchedSubscription

        List<MqttClientSubscription> getMatchedSubscription​(String topicName)
        获取匹配的订阅
        Parameters:
        topicName - topicName
        Returns:
        订阅信息集合

      • removeSubscriptions

        void removeSubscriptions​(List<String> topicFilters)
        删除订阅过程消息
        Parameters:
        topicFilters - topicFilter 集合

      • addPaddingUnSubscribe

        void addPaddingUnSubscribe​(int messageId,
                           br.com.anteros.mqtt.core.client.MqttPendingUnSubscription pendingUnSubscription)
        添加取消订阅过程消息
        Parameters:
        messageId - messageId
        pendingUnSubscription - MqttPendingUnSubscription

      • getPaddingUnSubscribe

        br.com.anteros.mqtt.core.client.MqttPendingUnSubscription getPaddingUnSubscribe​(int messageId)
        获取取消订阅过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingUnSubscription

      • removePaddingUnSubscribe

        br.com.anteros.mqtt.core.client.MqttPendingUnSubscription removePaddingUnSubscribe​(int messageId)
        删除取消订阅过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingUnSubscription

      • addPendingPublish

        void addPendingPublish​(int messageId,
                       MqttPendingPublish pendingPublish)
        添加过程消息
        Parameters:
        messageId - messageId
        pendingPublish - MqttPendingPublish

      • getPendingPublish

        MqttPendingPublish getPendingPublish​(int messageId)
        获取过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingPublish

      • removePendingPublish

        MqttPendingPublish removePendingPublish​(int messageId)
        删除过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingPublish

      • addPendingQos2Publish

        void addPendingQos2Publish​(int messageId,
                           MqttPendingQos2Publish pendingQos2Publish)
        添加 qos2 过程消息
        Parameters:
        messageId - messageId
        pendingQos2Publish - MqttPendingQos2Publish

      • getPendingQos2Publish

        MqttPendingQos2Publish getPendingQos2Publish​(int messageId)
        获取 qos2 过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingQos2Publish

      • removePendingQos2Publish

        MqttPendingQos2Publish removePendingQos2Publish​(int messageId)
        删除 qos2 过程消息
        Parameters:
        messageId - messageId
        Returns:
        MqttPendingQos2Publish

      • clean

        void clean()
        资源清理