package com.fastbee.mqtt.service;
|
|
import com.fastbee.mqtt.model.ClientMessage;
|
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author gsb
|
* @date 2022/10/14 14:35
|
*/
|
public interface IMessageStore {
|
|
/**
|
* 存储控制包
|
*
|
* @param topic: 控制包所属主题
|
* @param clientMessage: 需要存储的消息
|
*/
|
void storeMessage(String topic, ClientMessage clientMessage);
|
|
/**
|
* 清除topic下的所有消息
|
*
|
* @param topic: 主题
|
*/
|
void cleanTopic(String topic);
|
|
/**
|
* 根据clientId清除消息
|
*
|
* @param clientId: 客户端唯一标识
|
*/
|
void removeMessage(String clientId);
|
|
/**
|
* 匹配主题过滤器，寻找对应消息
|
*
|
* @param topicFilter: 主题过滤器
|
*/
|
List<ClientMessage> searchMessages(String topicFilter);
|
|
/**
|
* 保存 clientMessage
|
*
|
* @param messageId 消息id
|
*/
|
public void savePubMsg(Integer messageId, ClientMessage clientMessage);
|
|
/**
|
* 移除
|
*
|
* @param messageId 消息id
|
*/
|
public void removePubMsg(int messageId);
|
|
/**
|
* 保存 REL IN
|
*
|
* @param messageId 消息id
|
*/
|
public void saveRelInMsg(int messageId);
|
|
/**
|
* 保存 REL OUT
|
*
|
* @param messageId 消息id
|
*/
|
public void saveRelOutMsg(int messageId);
|
|
/**
|
* 移除
|
*
|
* @param messageId 消息id
|
*/
|
public void removeRelInMsg(int messageId);
|
|
/**
|
* 移除
|
*
|
* @param messageId 消息id
|
*/
|
public void removeRelOutMsg(int messageId);
|
|
/**
|
* 判断Rel out是否包含消息id
|
*/
|
public boolean outRelContains(int messageId);
|
|
}
|
