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

Interface IMqttMessageStore

  • All Known Implementing Classes:
    InMemoryMqttMessageStore
    public interface IMqttMessageStore
    message store
    Author:
    L.cm

    • Method Detail

      • addWillMessage

        boolean addWillMessage​(String clientId,
                       br.com.anteros.mqtt.core.server.model.Message message)
        存储 clientId 的遗嘱消息
        Parameters:
        clientId - clientId
        message - message
        Returns:
        boolean

      • clearWillMessage

        boolean clearWillMessage​(String clientId)
        清理该 clientId 的遗嘱消息
        Parameters:
        clientId - clientId
        Returns:
        boolean

      • getWillMessage

        br.com.anteros.mqtt.core.server.model.Message getWillMessage​(String clientId)
        获取 will 消息
        Parameters:
        clientId - clientId
        Returns:
        Message

      • addRetainMessage

        boolean addRetainMessage​(String topic,
                         br.com.anteros.mqtt.core.server.model.Message message)
        存储 retain 消息
        Parameters:
        topic - topic
        message - message
        Returns:
        boolean

      • clearRetainMessage

        boolean clearRetainMessage​(String topic)
        清理该 topic 的 retain 消息
        Parameters:
        topic - topic
        Returns:
        boolean

      • getRetainMessage

        List<br.com.anteros.mqtt.core.server.model.Message> getRetainMessage​(String topicFilter)
        获取所有 retain 消息
        Parameters:
        topicFilter - topicFilter
        Returns:
        Message