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