From bd008546b88cf862879c5ce1fb48b537d4f06f53 Mon Sep 17 00:00:00 2001 From: dongeforever Date: Fri, 10 Feb 2017 16:47:33 +0800 Subject: [PATCH] [ROCKETMQ-83] Fix quick start, annotate setNamesrvAddr, closes apache/incubator-rocketmq#54 --- .../org/apache/rocketmq/example/quickstart/Consumer.java | 6 +++++- .../org/apache/rocketmq/example/quickstart/Producer.java | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java index 58910abc..871edc28 100644 --- a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java +++ b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java @@ -42,8 +42,12 @@ public class Consumer { *

* * Alternatively, you may specify name server addresses via exporting environmental variable: NAMESRV_ADDR + *

+         * {@code
+         * consumer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876");
+         * }
+         * 
*/ - consumer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876"); /* * Specify where to start in case the specified consumer group is a brand new one. diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java index 06e1665e..53a1d4dd 100644 --- a/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java +++ b/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java @@ -38,8 +38,12 @@ public class Producer { *

* * Alternatively, you may specify name server addresses via exporting environmental variable: NAMESRV_ADDR + *

+         * {@code
+         * producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876");
+         * }
+         * 
*/ - producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876"); /* * Launch the instance. -- GitLab