com.github.thisxulz.redmq.client.producer

类 DefaultProducer

java.lang.Object

com.github.thisxulz.redmq.client.producer.DefaultProducer

public class DefaultProducer
extends Object

作者:

xulz

字段概要

字段

限定符和类型	字段和说明
private String	groupName
private static ClientLog	log
private ProducerService	producerService
private RedisService	redisService
private String	topicName

构造器概要

构造器

构造器和说明
DefaultProducer(String topicName, String groupName) 生产者，

方法概要

限定符和类型	方法和说明
boolean	checkTopicAndGroup()
String	getGroupName()
String	getTopicName()
void	sendMessage(String message)
void	setGroupName(String groupName)
void	setTopicName(String topicName)

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

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

字段详细资料

log

private static final ClientLog log

topicName

private String topicName

groupName

private String groupName

producerService

private ProducerService producerService

redisService

private RedisService redisService

构造器详细资料

DefaultProducer

public DefaultProducer(String topicName,
                       String groupName)

生产者，

参数:

topicName，消息主题 -

groupName，消费者group，为空的时候，消息发送给topic下所有group -

方法详细资料

sendMessage

public void sendMessage(String message)

checkTopicAndGroup

public boolean checkTopicAndGroup()

getTopicName

public String getTopicName()

setTopicName

public void setTopicName(String topicName)

getGroupName

public String getGroupName()

setGroupName

public void setGroupName(String groupName)