IntroDrop commented on a change in pull request #3034:
URL: https://github.com/apache/rocketmq/pull/3034#discussion_r656913546
##########
File path:
example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java
##########
@@ -65,6 +66,39 @@ public static void main(String[] args) throws
MQClientException, InterruptedExce
* Call send message to deliver message to one of brokers.
*/
SendResult sendResult = producer.send(msg);
+ /*
+ * There are different ways to send message, if you don't care
about the send result,you can use this way
+ * {@code
+ * producer.sendOneway(msg);
+ * }
+ */
+
+ /*
+ * if you want to get the send result in a synchronize way,
you can use this send method
+ * {@code
+ * SendResult sendResult = producer.send(msg);
+ * System.out.println(sendResult.toString());
Review comment:
private final static InternalLogger log = ClientLogger.getLog();
建议用log.info(),性能更高
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
