From f96840f1d347295446cb48c1134143161f3612dc Mon Sep 17 00:00:00 2001 From: mxsm Date: Fri, 9 Dec 2022 14:39:00 +0800 Subject: [PATCH] [ISSUE #5670] Add a note to the example of TimerMessage example (#5671) --- .../apache/rocketmq/example/schedule/TimerMessageConsumer.java | 3 +++ .../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 e4b2ba6fcf..788983592f 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 baa8da7c82..c4e3b4f3a1 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";