Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

框架使用rabbitmq作为broker时,如何控制noack和prefetchCount配置? #130

Open
xutaoding opened this issue Nov 3, 2024 · 1 comment

Comments

@xutaoding
Copy link

No description provided.

@ydf0509
Copy link
Owner

ydf0509 commented Nov 5, 2024

1.没有提供可选 ack模式,一律是需要确认,不能配置成noack。 因为ack更好,防丢失。 如果你需要ack,可以按照文档4.29扩展,参考原来的rabbitmq代码写法funboost/consumers/rabbitmq_amqpstorm_consumer.py。
2、.qos(self.consumer_params.concurrent_num) 配置的是并发数量的 预取出, 例如你设置并发数量为100,那么就是100,没有单独提供配置。

有的中间件有的地方细节没有单独提供配置,不满足就按文档扩展。

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants