opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5670] Add a note to the example of TimerMessage example (#5671)

Browse Source
This commit is contained in:
mxsm
2022-12-09 14:39:00 +08:00
committed by GitHub
parent aa02160074
commit f96840f1d3
2 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java
+3
View File
@@ -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";
example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java
+2
View File
@@ -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";