You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2021/10/26 12:05:28 UTC
[GitHub] [rocketmq] zyong2004 opened a new issue #3432: Producer must be start pullMessageService?
zyong2004 opened a new issue #3432:
URL: https://github.com/apache/rocketmq/issues/3432
Producer must be start pullMessageService?
` // Start pull service
//producer don't start pullMessageService
if (!getDefaultMQProducer().getProducerSide()) {
this.pullMessageService.start();
}`
it's ok?
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] panzhi33 commented on issue #3432: Producer must be start pullMessageService?
Posted by GitBox <gi...@apache.org>.
panzhi33 commented on issue #3432:
URL: https://github.com/apache/rocketmq/issues/3432#issuecomment-951963695
No need to start。IMO，If it is started, it will always be waiting to get tasks from the queue, and the thread will always be in the waiting state. Basically do not consume cpu resources
while (!this.isStopped()) {
try {
PullRequest pullRequest = this.pullRequestQueue.take();
this.pullMessage(pullRequest);
} catch (InterruptedException ignored) {
} catch (Exception e) {
log.error("Pull Message Service Run Method exception", e);
}
}
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin closed issue #3432: Producer must be start pullMessageService?
Posted by GitBox <gi...@apache.org>.
RongtongJin closed issue #3432:
URL: https://github.com/apache/rocketmq/issues/3432
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org