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

Class InMemoryMqttMessageStore

java.lang.Object

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

All Implemented Interfaces:

IMqttMessageStore

public class InMemoryMqttMessageStore
extends Object
implements IMqttMessageStore

message store

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
InMemoryMqttMessageStore()

Method Summary

Modifier and Type	Method	Description
boolean	addRetainMessage(String topic, br.com.anteros.mqtt.core.server.model.Message message)	存储 retain 消息
boolean	addWillMessage(String clientId, br.com.anteros.mqtt.core.server.model.Message message)	存储 clientId 的遗嘱消息
boolean	clearRetainMessage(String topic)	清理该 topic 的 retain 消息
boolean	clearWillMessage(String clientId)	清理该 clientId 的遗嘱消息
List<br.com.anteros.mqtt.core.server.model.Message>	getRetainMessage(String topicFilter)	获取所有 retain 消息
br.com.anteros.mqtt.core.server.model.Message	getWillMessage(String clientId)	获取 will 消息

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMqttMessageStore

public InMemoryMqttMessageStore()

Method Detail

addWillMessage

public boolean addWillMessage(String clientId,
                              br.com.anteros.mqtt.core.server.model.Message message)

Description copied from interface: IMqttMessageStore

存储 clientId 的遗嘱消息

Specified by:

addWillMessage in interface IMqttMessageStore

Parameters:

clientId - clientId

message - message

Returns:

boolean

clearWillMessage

public boolean clearWillMessage(String clientId)

Description copied from interface: IMqttMessageStore

清理该 clientId 的遗嘱消息

Specified by:

clearWillMessage in interface IMqttMessageStore

Parameters:

clientId - clientId

Returns:

boolean

getWillMessage

public br.com.anteros.mqtt.core.server.model.Message getWillMessage(String clientId)

Description copied from interface: IMqttMessageStore

获取 will 消息

Specified by:

getWillMessage in interface IMqttMessageStore

Parameters:

clientId - clientId

Returns:

Message

addRetainMessage

public boolean addRetainMessage(String topic,
                                br.com.anteros.mqtt.core.server.model.Message message)

Description copied from interface: IMqttMessageStore

存储 retain 消息

Specified by:

addRetainMessage in interface IMqttMessageStore

Parameters:

topic - topic

message - message

Returns:

boolean

clearRetainMessage

public boolean clearRetainMessage(String topic)

Description copied from interface: IMqttMessageStore

清理该 topic 的 retain 消息

Specified by:

clearRetainMessage in interface IMqttMessageStore

Parameters:

topic - topic

Returns:

boolean

getRetainMessage

public List<br.com.anteros.mqtt.core.server.model.Message> getRetainMessage(String topicFilter)

Description copied from interface: IMqttMessageStore

获取所有 retain 消息

Specified by:

getRetainMessage in interface IMqttMessageStore

Parameters:

topicFilter - topicFilter

Returns:

Message