From 38d71d9a2256c4cafefd487daa50cbd5f46f6896 Mon Sep 17 00:00:00 2001 From: dinglei Date: Thu, 31 Jan 2019 10:59:29 +0800 Subject: [PATCH] Update AsyncProducer.java --- .../java/org/apache/rocketmq/example/simple/AsyncProducer.java | 1 - 1 file changed, 1 deletion(-) diff --git a/example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java b/example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java index 9150974a5c..d40739c813 100644 --- a/example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java +++ b/example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java @@ -31,7 +31,6 @@ public class AsyncProducer { String[] args) throws MQClientException, InterruptedException, UnsupportedEncodingException { DefaultMQProducer producer = new DefaultMQProducer("Jodie_Daily_test"); - producer.setNamesrvAddr("139.196.101.149:9876"); producer.start(); producer.setRetryTimesWhenSendAsyncFailed(0);