chennaji9 opened a new issue, #11332:
URL: https://github.com/apache/rocketmq/issues/11332

   ### Description
   
   The OpenMessaging producer example 
`example/src/main/java/org/apache/rocketmq/example/openmessaging/SimpleProducer.java`
 labels its **synchronous** send as async:
   
   ```java
   SendResult sendResult = producer.send(message);          // synchronous send
   ...
   System.out.printf("Send async message OK, msgId: %s%n", 
sendResult.messageId());
   ```
   
   The genuinely asynchronous path further down (`producer.sendAsync(...)` with 
a listener) prints the same "Send async message OK" line, so running the demo 
produces two indistinguishable "async" lines even though the first send is 
blocking. Anyone learning from the sample cannot tell which output belongs to 
which send mode.
   
   ### Expected behavior
   
   The synchronous block should print `Send sync message OK`, keeping the 
"async" wording for the `sendAsync` listener path (which already distinguishes 
success/failure).


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to