This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 28e6b55 [ISSUE #2299]modify the error character of the
Example_Filter.md
28e6b55 is described below
commit 28e6b557ad9796ceaf9bc5603ce9802cd5ee845d
Author: yazong <[email protected]>
AuthorDate: Fri Sep 18 11:35:45 2020 +0800
[ISSUE #2299]modify the error character of the Example_Filter.md
---
docs/en/Example_Filter.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/en/Example_Filter.md b/docs/en/Example_Filter.md
index caf34cb..8c95a91 100644
--- a/docs/en/Example_Filter.md
+++ b/docs/en/Example_Filter.md
@@ -74,7 +74,7 @@ Use `MessageSelector.bySql` to select messages through SQL
when consuming.
```java
DefaultMQPushConsumer consumer = new
DefaultMQPushConsumer("please_rename_unique_group_name_4");
// only subsribe messages have property a, also a >=0 and a <= 3
-consumer.subscribe("TopicTest", MessageSelector.bySql("a between 0 and 3");
+consumer.subscribe("TopicTest", MessageSelector.bySql("a between 0 and 3"));
consumer.registerMessageListener(new MessageListenerConcurrently() {
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
ConsumeConcurrentlyContext context) {
