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

Merge pull request #3033 from zyh-future/zyh_asuncproducer_doc_fix

Browse Source 
Looking at the Chinese document, I found that the subtraction operati…
This commit is contained in:
Heng Du
2021-08-04 09:18:06 +08:00
committed by GitHub
parent bb34171289 9d4e8de315
commit 0fdc73d473
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
docs/cn/RocketMQ_Example.md
+4 -2
View File
@@ -120,13 +120,15 @@ public class AsyncProducer {
producer.send(msg, new SendCallback() {
@Override
public void onSuccess(SendResult sendResult) {
countDownLatch.countDown();
System.out.printf("%-10d OK %s %n", index,
sendResult.getMsgId());
}
@Override
public void onException(Throwable e) {
System.out.printf("%-10d Exception %s %n", index, e);
e.printStackTrace();
countDownLatch.countDown();
System.out.printf("%-10d Exception %s %n", index, e);
e.printStackTrace();
}
});
}