com.github.thisxulz.redmq.web.service

接口 DataService

所有已知实现类:

DataServiceImpl

public interface DataService

作者:

xulz

方法概要

限定符和类型	方法和说明
int	changeConsumerStatus(String topic, String group, int status) 开启/关闭消费者
Set<String>	getAllGroups() 获取所有注册的groups
List<MsgListStatus>	getAllMsgList() 获取所有消息队列
Set<String>	getAllTopics() 获取所有的注册topic
Set<String>	getGroupTopics(String group) 获取消费者分组监听的主题
MsgListStatus	getMsgList(String topic, String group) 获取消息队列长度，剩余未处理消息
Set<String>	getTopicGroups(String topic) 获取主题下注册的消费者分组

方法详细资料

getAllTopics

Set<String> getAllTopics()

获取所有的注册topic

返回:

getAllGroups

Set<String> getAllGroups()

获取所有注册的groups

返回:

getTopicGroups

Set<String> getTopicGroups(String topic)

获取主题下注册的消费者分组

参数:

topic -

返回:

getGroupTopics

Set<String> getGroupTopics(String group)

获取消费者分组监听的主题

参数:

group -

返回:

getMsgList

MsgListStatus getMsgList(String topic,
                         String group)

获取消息队列长度，剩余未处理消息

参数:

topic -

group -

返回:

getAllMsgList

List<MsgListStatus> getAllMsgList()

获取所有消息队列

返回:

changeConsumerStatus

int changeConsumerStatus(String topic,
                         String group,
                         int status)

开启/关闭消费者

参数:

topic -

group -

status -

返回: