public class RocketMQConsumerInfo extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
private String |
accessKey
The property of "access-key".
|
private String |
customizedTraceTopic
The name value of message trace topic.If you don't config,you can use the default trace topic name.
|
private boolean |
enableMsgTrace
Switch flag instance for message trace.
|
private String |
group
Group name of consumer.
|
private Map<String,Map<String,Boolean>> |
listeners
Listener configuration container.
|
private String |
messageModel
Control message mode, if you want all subscribers receive message all message, broadcasting is a good choice.
|
private int |
pullBatchSize
Maximum number of messages pulled each time.
|
private RocketMQConsumerRegistrarInfo |
registrar |
private String |
secretKey
The property of "secret-key".
|
private String |
selectorExpression
Control which message can be select.
|
private String |
selectorType
Control how to selector message.
|
private String |
topic
Topic name of consumer.
|
| 构造器和说明 |
|---|
RocketMQConsumerInfo() |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
equals(Object obj) |
String |
getAccessKey() |
String |
getCustomizedTraceTopic() |
String |
getGroup() |
Map<String,Map<String,Boolean>> |
getListeners() |
String |
getMessageModel() |
int |
getPullBatchSize() |
RocketMQConsumerRegistrarInfo |
getRegistrar() |
String |
getSecretKey() |
String |
getSelectorExpression() |
String |
getSelectorType() |
String |
getTopic() |
int |
hashCode() |
boolean |
isEnableMsgTrace() |
void |
setAccessKey(String accessKey) |
void |
setCustomizedTraceTopic(String customizedTraceTopic) |
void |
setEnableMsgTrace(boolean enableMsgTrace) |
void |
setGroup(String group) |
void |
setListeners(Map<String,Map<String,Boolean>> listeners) |
void |
setMessageModel(String messageModel) |
void |
setPullBatchSize(int pullBatchSize) |
void |
setSecretKey(String secretKey) |
void |
setSelectorExpression(String selectorExpression) |
void |
setSelectorType(String selectorType) |
void |
setTopic(String topic) |
String |
toString() |
private String group
private String topic
private String messageModel
private String selectorType
private String selectorExpression
private String accessKey
private String secretKey
private int pullBatchSize
private boolean enableMsgTrace
private String customizedTraceTopic
private Map<String,Map<String,Boolean>> listeners
private final RocketMQConsumerRegistrarInfo registrar
public String getGroup()
public void setGroup(String group)
public String getTopic()
public void setTopic(String topic)
public String getMessageModel()
public void setMessageModel(String messageModel)
public String getSelectorType()
public void setSelectorType(String selectorType)
public String getSelectorExpression()
public void setSelectorExpression(String selectorExpression)
public String getAccessKey()
public void setAccessKey(String accessKey)
public String getSecretKey()
public void setSecretKey(String secretKey)
public int getPullBatchSize()
public void setPullBatchSize(int pullBatchSize)
public boolean isEnableMsgTrace()
public void setEnableMsgTrace(boolean enableMsgTrace)
public String getCustomizedTraceTopic()
public void setCustomizedTraceTopic(String customizedTraceTopic)
public RocketMQConsumerRegistrarInfo getRegistrar()
Copyright © 2025 Zodiac. All rights reserved.