Skip to content

Commit 7fc0833

Browse files
committed
update tag
1 parent 6923181 commit 7fc0833

2 files changed

Lines changed: 6 additions & 3 deletions

File tree

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/ExtConsumerResetConfiguration.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,11 @@
3131

3232
String ACCESS_KEY_PLACEHOLDER = "${rocketmq.simple-consumer.accessKey:}";
3333
String SECRET_KEY_PLACEHOLDER = "${rocketmq.simple-consumer.secretKey:}";
34+
String TAG_PLACEHOLDER = "${rocketmq.simple-consumer.tag:*}";
3435
String TOPIC_PLACEHOLDER = "${rocketmq.simple-consumer.topic:}";
3536
String ENDPOINTS_PLACEHOLDER = "${rocketmq.simple-consumer.endpoints:}";
3637
String CONSUMER_GROUP_PLACEHOLDER = "${rocketmq.simple-consumer.consumerGroup:}";
38+
String FILTER_EXPRESSION_TYPE_PLACEHOLDER = "${rocketmq.simple-consumer.filterExpressionType:tag}";
3739

3840
/**
3941
* The component name of the Consumer configuration.
@@ -55,7 +57,7 @@
5557
* For TAG selectorType, use "*" to subscribe all messages, or use "tagA||tagB" for multiple tags.
5658
* For SQL92 selectorType, use SQL92 expression like "a > 5 AND b < 10".
5759
*/
58-
String tag() default "*";
60+
String tag() default TAG_PLACEHOLDER;
5961

6062
/**
6163
* Topic name of consumer.
@@ -84,7 +86,7 @@
8486
* This field will be removed in a future version.
8587
*/
8688
@Deprecated
87-
String filterExpressionType() default "tag";
89+
String filterExpressionType() default FILTER_EXPRESSION_TYPE_PLACEHOLDER;
8890

8991
/**
9092
* The requestTimeout of client,it is 3s by default.

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
String SECRET_KEY_PLACEHOLDER = "${rocketmq.push-consumer.secret-key:}";
3232
String ENDPOINTS_PLACEHOLDER = "${rocketmq.push-consumer.endpoints:}";
3333
String TOPIC_PLACEHOLDER = "${rocketmq.push-consumer.topic:}";
34+
String TAG_PLACEHOLDER = "${rocketmq.push-consumer.tag:*}";
3435

3536
/**
3637
* The property of "access-key".
@@ -64,7 +65,7 @@
6465
* For TAG type, use "*" to subscribe all messages, or use "tagA||tagB" for multiple tags.
6566
* For SQL92 type, use SQL92 expression like "a > 5 AND b < 10".
6667
*/
67-
String tag() default "*";
68+
String tag() default TAG_PLACEHOLDER;
6869

6970
/**
7071
* Enable or disable the use of Secure Sockets Layer (SSL) for network transport.

0 commit comments

Comments
 (0)