org.zodiac.rocketmq.client.config

类 RocketMQInfo

java.lang.Object

org.zodiac.rocketmq.client.config.RocketMQInfo

public class RocketMQInfo
extends Object

字段概要

字段

限定符和类型	字段和说明
private String	accessChannel Enum type for accessChannel, values: LOCAL, CLOUD
private RocketMQConsumerInfo	consumer Configure enable listener or not.
private String	nameServer The name server for rocketMQ, formats: `host:port;host:port`.
private RocketMQProducerInfo	producer

构造器概要

构造器

构造器和说明
RocketMQInfo()

方法概要

限定符和类型	方法和说明
boolean	equals(Object obj)
String	getAccessChannel()
RocketMQConsumerInfo	getConsumer()
String	getNameServer()
RocketMQProducerInfo	getProducer()
int	hashCode()
void	setAccessChannel(String accessChannel)
void	setConsumer(RocketMQConsumerInfo consumer)
void	setNameServer(String nameServer)
void	setProducer(RocketMQProducerInfo producer)
String	toString()

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

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

字段详细资料

nameServer

private String nameServer

The name server for rocketMQ, formats: `host:port;host:port`.

accessChannel

private String accessChannel

Enum type for accessChannel, values: LOCAL, CLOUD

producer

private RocketMQProducerInfo producer

consumer

private RocketMQConsumerInfo consumer

Configure enable listener or not. In some particular cases, if you don't want the the listener is enabled when container startup, the configuration pattern is like this : rocketmq.consumer.listeners.<group-name>.<topic-name>.enabled=<boolean value, true or false>

the listener is enabled by default.

构造器详细资料

RocketMQInfo

public RocketMQInfo()

方法详细资料

getNameServer

public String getNameServer()

setNameServer

public void setNameServer(String nameServer)

getAccessChannel

public String getAccessChannel()

setAccessChannel

public void setAccessChannel(String accessChannel)

getProducer

public RocketMQProducerInfo getProducer()

setProducer

public void setProducer(RocketMQProducerInfo producer)

getConsumer

public RocketMQConsumerInfo getConsumer()

setConsumer

public void setConsumer(RocketMQConsumerInfo consumer)

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object