aaron-ai commented on issue #3973: URL: https://github.com/apache/rocketmq/issues/3973#issuecomment-1092522761
> 返回 `Future` 并不影响开发者在后续处理中使用 `CompletableFuture` 中提供的回调方法、因为开发者可以在具体的实现中返回 `Futrue` 的实现类 `CompletableFuture`。 Could you provide an example to add callback or convert `Future` to `CompletableFuture` if there is a method for message publishing like this? ```java Future<SendReceipt> sendAsync(Message message); ``` About the `RetryPolicy`, actually it is not public, which means it is not exposed to users, `maxAttempts` could also be modified in `BackoffRetryPolicy`, but we may reconsider that if it is reasonable enough to keep `RetryPolicy` in this module. -- 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]
