如何解决配置@JmsListener以限制消息速率
我已经实现了@JmsListener来监听来自Producer的消息。
APP <- Consumer <- Producer
因此，如上Consumer所示，正在消耗生产者的消息并调用应用程序（APP）来处理这些消息，在这种情况下，应用程序运行缓慢，我们希望限制从队列{消耗的消息的速率{1}}
(Consumer <- Producer)找到一种方法来限制来自Producer的消息速率，这可以通过限制订阅或具有并发性但找不到任何支持 @JmsListener(
containerFactory = XXX destination = XXX) public void receive(Message message) throws JMSException {
}
注释的方式来完成
解决方法
有一个@JmsListener concurrency选项：
侦听器的并发限制（如果有）。覆盖价值 由用于创建侦听器的容器工厂定义 容器。
并发限制可以是“上下”字符串-例如， “ 5-10”（或简单的上限字符串），例如“ 10”，其中 下限为1。
请注意，基础容器可能支持也可能不支持全部 特征。例如，在这种情况下，它可能无法缩放 仅使用上限。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
