diff --git a/docs/cn/Example_Delay.md b/docs/cn/Example_Delay.md index 31df40f4485..4575f04e41d 100644 --- a/docs/cn/Example_Delay.md +++ b/docs/cn/Example_Delay.md @@ -15,6 +15,8 @@ public class ScheduledMessageConsumer { public static void main(String[] args) throws Exception { // Instantiate message consumer DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ExampleConsumer"); + // 设置NameServer地址 + consumer.setNamesrvAddr("localhost:9876"); // Subscribe topics consumer.subscribe("TestTopic", "*"); // Register message listener @@ -46,6 +48,8 @@ public class ScheduledMessageProducer { public static void main(String[] args) throws Exception { // Instantiate a producer to send scheduled messages DefaultMQProducer producer = new DefaultMQProducer("ExampleProducerGroup"); + // 设置NameServer地址 + producer.setNamesrvAddr("localhost:9876"); // Launch producer producer.start(); int totalMessagesToSend = 100;