[ROCKETMQ-83] Fix quick start, annotate setNamesrvAddr, closes apache/incubator-rocketmq#54
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/bd008546 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/bd008546 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/bd008546 Branch: refs/heads/release-4.0.0-incubating Commit: bd008546b88cf862879c5ce1fb48b537d4f06f53 Parents: 7d9eac4 Author: dongeforever <zhendongli...@yeah.net> Authored: Fri Feb 10 16:47:33 2017 +0800 Committer: yukon <yu...@apache.org> Committed: Fri Feb 10 16:47:33 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/rocketmq/example/quickstart/Consumer.java | 6 +++++- .../java/org/apache/rocketmq/example/quickstart/Producer.java | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/bd008546/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java ---------------------------------------------------------------------- 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 58910ab..871edc2 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 { * <p/> * * Alternatively, you may specify name server addresses via exporting environmental variable: NAMESRV_ADDR + * <pre> + * {@code + * consumer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876"); + * } + * </pre> */ - 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. http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/bd008546/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java ---------------------------------------------------------------------- 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 06e1665..53a1d4d 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 { * <p/> * * Alternatively, you may specify name server addresses via exporting environmental variable: NAMESRV_ADDR + * <pre> + * {@code + * producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876"); + * } + * </pre> */ - producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876"); /* * Launch the instance.
