com.github.thisxulz.redmq.client.consumer

类 DefaultConsumer

java.lang.Object

com.github.thisxulz.redmq.client.consumer.DefaultConsumer

public class DefaultConsumer
extends Object

作者:

xulz

字段概要

字段

限定符和类型	字段和说明
private ConsumerService	consumerService
private String	groupName
private static ClientLog	log
private MessageLinser	messageLinser
private RedisService	redisService
private int	threadNum
private String	topicName

构造器概要

构造器

构造器和说明
DefaultConsumer(String topicName, String groupName)
DefaultConsumer(String topicName, String groupName, int threadNum)

方法概要

限定符和类型	方法和说明
String	getGroupName()
MessageLinser	getMessageLinser()
String	getTopicName()
void	setGroupName(String groupName)
void	setMessageLinser(MessageLinser messageLinser)
void	setTopicName(String topicName)
void	start()

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

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

字段详细资料

log

private static final ClientLog log

threadNum

private int threadNum

topicName

private String topicName

groupName

private String groupName

consumerService

private ConsumerService consumerService

redisService

private RedisService redisService

messageLinser

private MessageLinser messageLinser

构造器详细资料

DefaultConsumer

public DefaultConsumer(String topicName,
                       String groupName,
                       int threadNum)

DefaultConsumer

public DefaultConsumer(String topicName,
                       String groupName)

方法详细资料

start

public void start()

getTopicName

public String getTopicName()

setTopicName

public void setTopicName(String topicName)

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)

setMessageLinser

public void setMessageLinser(MessageLinser messageLinser)

getMessageLinser

public MessageLinser getMessageLinser()