Git-Yang commented on issue #1671:
URL: https://github.com/apache/rocketmq/issues/1671#issuecomment-973878051
> So how to solve this problem?
A custom thread pool and a good rejection strategy may be a good choice.
` /**`
` * Sets an Executor to be used for executing asynchronous send. If the
Executor is not set, {@link`
` * DefaultMQProducerImpl#defaultAsyncSenderExecutor} will be used.`
` *`
` * @param asyncSenderExecutor the instance of Executor`
` */`
` public void setAsyncSenderExecutor(final ExecutorService
asyncSenderExecutor) {`
`
this.defaultMQProducerImpl.setAsyncSenderExecutor(asyncSenderExecutor);`
` }`
--
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]
