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

Update AsyncProducer.java

Browse Source
This commit is contained in:
dinglei
2019-01-31 10:59:29 +08:00
committed by GitHub
parent 6021e46b11
commit 38d71d9a22
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java
-1
View File
@@ -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);