You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/12/09 06:39:13 UTC
[rocketmq] branch develop updated: [ISSUE #5670] Add a note to the example of TimerMessage example (#5671)
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 f96840f1d [ISSUE #5670] Add a note to the example of TimerMessage example (#5671)
f96840f1d is described below
commit f96840f1d347295446cb48c1134143161f3612dc
Author: mxsm <lj...@gmail.com>
AuthorDate: Fri Dec 9 14:39:00 2022 +0800
[ISSUE #5670] Add a note to the example of TimerMessage example (#5671)
---
.../org/apache/rocketmq/example/schedule/TimerMessageConsumer.java | 3 +++
.../org/apache/rocketmq/example/schedule/TimerMessageProducer.java | 2 ++
2 files changed, 5 insertions(+)
diff --git a/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java b/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java
index e4b2ba6fc..788983592 100644
--- a/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java
@@ -22,6 +22,9 @@ import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;
public class TimerMessageConsumer {
+
+ //Note: TimerMessage is a new feature in version 5.0, so be sure to upgrade RocketMQ to version 5.0+ before using it.
+
public static final String CONSUMER_GROUP = "TimerMessageConsumerGroup";
public static final String DEFAULT_NAMESRVADDR = "127.0.0.1:9876";
public static final String TOPIC = "TimerTopic";
diff --git a/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java b/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java
index baa8da7c8..c4e3b4f3a 100644
--- a/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java
@@ -23,6 +23,8 @@ import org.apache.rocketmq.common.message.Message;
public class TimerMessageProducer {
+ //Note: TimerMessage is a new feature in version 5.0, so be sure to upgrade RocketMQ to version 5.0+ before using it.
+
public static final String PRODUCER_GROUP = "TimerMessageProducerGroup";
public static final String DEFAULT_NAMESRVADDR = "127.0.0.1:9876";
public static final String TOPIC = "TimerTopic";