org.zodiac.rocketmq.client

注释类型 RocketMQConsumerMessageListener

@Documented
 @Target(value=TYPE)
 @Retention(value=RUNTIME)
public @interface RocketMQConsumerMessageListener

必需元素概要

所需元素

限定符和类型	必需的元素和说明
String	clientConfig
String	consumerGroup Consumers of the same role is required to have exactly same subscriptions and consumerGroup to correctly achieve load balance.
String	topic Topic name.

可选元素概要

可选元素

限定符和类型	可选元素和说明
String	accessChannel The property of "access-channel".
String	accessKey The property of "access-key".
org.apache.rocketmq.spring.annotation.ConsumeMode	consumeMode Control consume mode, you can choice receive message concurrently or orderly.
int	consumeThreadMax Max consumer thread number.
long	consumeTimeout Maximum amount of time in minutes a message may block the consuming thread.
String	customizedTraceTopic The name value of message trace topic.If you don't config,you can use the default trace topic name.
boolean	enableMsgTrace Switch flag instance for message trace.
int	maxReconsumeTimes Max re-consume times.
org.apache.rocketmq.spring.annotation.MessageModel	messageModel Control message mode, if you want all subscribers receive message all message, broadcasting is a good choice.
String	nameServer The property of "name-server".
int	replyTimeout Timeout for sending reply messages.
String	secretKey The property of "secret-key".
String	selectorExpression Control which message can be select.
org.apache.rocketmq.spring.annotation.SelectorType	selectorType Control how to selector message.

元素详细资料

clientConfig

public abstract String clientConfig

consumerGroup

public abstract String consumerGroup

Consumers of the same role is required to have exactly same subscriptions and consumerGroup to correctly achieve load balance. It's required and needs to be globally unique. See here for further discussion.

返回:

Group.

topic

public abstract String topic

Topic name.

返回:

Topic.

selectorType

public abstract org.apache.rocketmq.spring.annotation.SelectorType selectorType

Control how to selector message.

返回:

SelectorType.

另请参阅:

SelectorType

默认值:

org.apache.rocketmq.spring.annotation.SelectorType.TAG

selectorExpression

public abstract String selectorExpression

Control which message can be select. Grammar please see SelectorType.TAG and SelectorType.SQL92

返回:

Expression.

默认值:

"*"

consumeMode

public abstract org.apache.rocketmq.spring.annotation.ConsumeMode consumeMode

Control consume mode, you can choice receive message concurrently or orderly.

返回:

ConsumeMode.

默认值:

org.apache.rocketmq.spring.annotation.ConsumeMode.CONCURRENTLY

messageModel

public abstract org.apache.rocketmq.spring.annotation.MessageModel messageModel

Control message mode, if you want all subscribers receive message all message, broadcasting is a good choice.

返回:

MessageModel.

默认值:

org.apache.rocketmq.spring.annotation.MessageModel.CLUSTERING

consumeThreadMax

public abstract int consumeThreadMax

Max consumer thread number.

返回:

Maximum number of threads.

默认值:

64

maxReconsumeTimes

public abstract int maxReconsumeTimes

Max re-consume times. In concurrently mode, -1 means 16; In orderly mode, -1 means Integer.MAX_VALUE.

返回:

Times.

默认值:

-1

consumeTimeout

public abstract long consumeTimeout

Maximum amount of time in minutes a message may block the consuming thread.

返回:

Timeout.

默认值:

15L

replyTimeout

public abstract int replyTimeout

Timeout for sending reply messages.

返回:

Timeout.

默认值:

3000

accessKey

public abstract String accessKey

The property of "access-key".

返回:

Access tkey.

默认值:

"${rocketmq.consumer.access-key:}"

secretKey

public abstract String secretKey

The property of "secret-key".

返回:

Secret tkey.

默认值:

"${rocketmq.consumer.secret-key:}"

enableMsgTrace

public abstract boolean enableMsgTrace

Switch flag instance for message trace.

返回:

Is message trace enabled.

默认值:

false

customizedTraceTopic

public abstract String customizedTraceTopic

The name value of message trace topic.If you don't config,you can use the default trace topic name.

返回:

Trace topic.

默认值:

"${rocketmq.consumer.customized-trace-topic:}"

nameServer

public abstract String nameServer

The property of "name-server".

返回:

Name server.

默认值:

"${rocketmq.name-server:}"

accessChannel

public abstract String accessChannel

The property of "access-channel".

返回:

Access channel.

默认值:

"${rocketmq.access-channel:}"