public class RocketmqConfig
extends java.lang.Object
| 构造器和说明 |
|---|
RocketmqConfig(CloudProps cloudProps) |
| 限定符和类型 | 方法和说明 |
|---|---|
java.lang.String |
getAccessKey() |
java.lang.String |
getChannelName() |
CloudProps |
getCloudProps() |
java.lang.String |
getConsumerGroup()
消费组
|
int |
getConsumeThreadNums()
实例的消费线程数,0表示默认
|
int |
getMaxReconsumeTimes()
设置消息消费失败的最大重试次数,0表示默认
|
java.lang.String |
getNamespace()
命名空间
|
java.lang.String |
getProducerGroup()
产品组
|
java.lang.String |
getSecretKey() |
java.lang.String |
getServer() |
long |
getTimeout() |
public RocketmqConfig(CloudProps cloudProps)
public CloudProps getCloudProps()
public java.lang.String getNamespace()
public java.lang.String getConsumerGroup()
public java.lang.String getProducerGroup()
public java.lang.String getChannelName()
public java.lang.String getServer()
public java.lang.String getAccessKey()
public java.lang.String getSecretKey()
public long getTimeout()
public int getConsumeThreadNums()
public int getMaxReconsumeTimes()