RocketMQConsumerInfo (Zodiac RocketMQ 1.7.1 API)

java.lang.Object
- org.zodiac.rocketmq.client.config.consumer.RocketMQConsumerInfo

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()

构造器
构造器和说明
`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()`

从类继承的方法 java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

字段详细资料
- group
```
private String group
```
  Group name of consumer.
- topic
```
private String topic
```
  Topic name of consumer.
- messageModel
```
private String messageModel
```
  Control message mode, if you want all subscribers receive message all message, broadcasting is a good choice.
- selectorType
```
private String selectorType
```
  Control how to selector message.
- selectorExpression
```
private String selectorExpression
```
  Control which message can be select.
- accessKey
```
private String accessKey
```
  The property of "access-key".
- secretKey
```
private String secretKey
```
  The property of "secret-key".
- pullBatchSize
```
private int pullBatchSize
```
  Maximum number of messages pulled each time.
- enableMsgTrace
```
private boolean enableMsgTrace
```
  Switch flag instance for message trace.
- customizedTraceTopic
```
private String customizedTraceTopic
```
  The name value of message trace topic.If you don't config,you can use the default trace topic name.
- listeners
```
private Map<String,Map<String,Boolean>> listeners
```
  Listener configuration container.
  The pattern is like this:
  - group1.topic1 = false
  - group2.topic2 = true
  - group3.topic3 = false
- registrar
```
private final RocketMQConsumerRegistrarInfo registrar
```

构造器详细资料
- RocketMQConsumerInfo
```
public RocketMQConsumerInfo()
```

方法详细资料

getGroup
```
public String getGroup()
```

setGroup
```
public void setGroup(String group)
```

getTopic
```
public String getTopic()
```

setTopic
```
public void setTopic(String topic)
```

getMessageModel
```
public String getMessageModel()
```

setMessageModel

public void setMessageModel(String messageModel)

getSelectorType
```
public String getSelectorType()
```

setSelectorType

public void setSelectorType(String selectorType)

getSelectorExpression
```
public String getSelectorExpression()
```

setSelectorExpression

public void setSelectorExpression(String selectorExpression)

getAccessKey
```
public String getAccessKey()
```

setAccessKey

public void setAccessKey(String accessKey)

getSecretKey
```
public String getSecretKey()
```

setSecretKey

public void setSecretKey(String secretKey)

getPullBatchSize
```
public int getPullBatchSize()
```

setPullBatchSize

public void setPullBatchSize(int pullBatchSize)

getListeners

public Map<String,Map<String,Boolean>> getListeners()

setListeners

public void setListeners(Map<String,Map<String,Boolean>> listeners)

isEnableMsgTrace
```
public boolean isEnableMsgTrace()
```

setEnableMsgTrace

public void setEnableMsgTrace(boolean enableMsgTrace)

getCustomizedTraceTopic

public String getCustomizedTraceTopic()

setCustomizedTraceTopic

public void setCustomizedTraceTopic(String customizedTraceTopic)

getRegistrar

public RocketMQConsumerRegistrarInfo getRegistrar()

hashCode
```
public int hashCode()
```
覆盖:

hashCode 在类中 Object

equals
```
public boolean equals(Object obj)
```
覆盖:

equals 在类中 Object

toString
```
public String toString()
```
覆盖:

toString 在类中 Object

类 RocketMQConsumerInfo

字段概要

构造器概要

方法概要

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

字段详细资料

group

topic

messageModel

selectorType

selectorExpression

accessKey

secretKey

pullBatchSize

enableMsgTrace

customizedTraceTopic

listeners

registrar

构造器详细资料

RocketMQConsumerInfo

方法详细资料

getGroup

setGroup

getTopic

setTopic

getMessageModel

setMessageModel

getSelectorType

setSelectorType

getSelectorExpression

setSelectorExpression

getAccessKey

setAccessKey

getSecretKey

setSecretKey

getPullBatchSize

setPullBatchSize

getListeners

setListeners

isEnableMsgTrace

setEnableMsgTrace

getCustomizedTraceTopic

setCustomizedTraceTopic

getRegistrar

hashCode

equals

toString