com.github.thisxulz.redmq.web.service.impl

类 DataServiceImpl

java.lang.Object

com.github.thisxulz.redmq.web.service.impl.DataServiceImpl

所有已实现的接口:

DataService

@Service
public class DataServiceImpl
extends Object
implements DataService

作者:

xulz

字段概要

字段

限定符和类型	字段和说明
private static org.slf4j.Logger	log

构造器概要

构造器

构造器和说明
DataServiceImpl()

方法概要

限定符和类型	方法和说明
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) 获取主题下注册的消费者分组

从类继承的方法 java.lang.Object

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

字段详细资料

log

private static final org.slf4j.Logger log

构造器详细资料

DataServiceImpl

public DataServiceImpl()

方法详细资料

getAllTopics

public Set<String> getAllTopics()

从接口复制的说明: DataService

获取所有的注册topic

指定者:

getAllTopics 在接口中 DataService

返回:

getAllGroups

public Set<String> getAllGroups()

从接口复制的说明: DataService

获取所有注册的groups

指定者:

getAllGroups 在接口中 DataService

返回:

getTopicGroups

public Set<String> getTopicGroups(String topic)

从接口复制的说明: DataService

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

指定者:

getTopicGroups 在接口中 DataService

返回:

getGroupTopics

public Set<String> getGroupTopics(String group)

从接口复制的说明: DataService

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

指定者:

getGroupTopics 在接口中 DataService

返回:

getMsgList

public MsgListStatus getMsgList(String topic,
                                String group)

从接口复制的说明: DataService

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

指定者:

getMsgList 在接口中 DataService

返回:

getAllMsgList

public List<MsgListStatus> getAllMsgList()

从接口复制的说明: DataService

获取所有消息队列

指定者:

getAllMsgList 在接口中 DataService

返回:

changeConsumerStatus

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

从接口复制的说明: DataService

开启/关闭消费者

指定者:

changeConsumerStatus 在接口中 DataService

返回: