out-of-memory - 由于多个消费者 ActiveMQ 导致内存不足
问题描述
我正在使用 DefaultMessageListenerContainer 如下:
private static final AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(MessageConsumer.class);
public static final DefaultMessageListenerContainer container = context.getBean(DefaultMessageListenerContainer.class);
对于我的侦听器侦听的给定队列,我的程序第一次运行时会启动侦听器......这将为我可以在 Active MQ 控制台中看到的队列创建一个使用者。
我遇到的问题是每次我签入一些新代码时,都会为队列创建另一个新的消费者,而旧的消费者仍在创建一些内存不足问题。
我在这里做错了什么?如何确保只有 1 个消费者并且每次新代码签入都会杀死旧消费者?希望我清楚地解释了这个问题。
解决方案
推荐阅读
- weblog - Web 服务器日志数据中的最后一个字段是关于什么的?
- java - 如何“交换”数组中的两个值?
- visual-studio-code - ProcessException:进程“C:\Users\...\android\gradlew.bat”异常退出:
- java - Maven 在 Jenkins 上失败(目标存储库不能为空)但不是本地的
- wordpress - 如何在 Compute Engine 上为 1000 个活跃用户选择机器类型
- java - 如何让休眠不查询孩子?
- python - 如何在一个 for 语句中从头到尾访问项目
- amazon-web-services - Ansible 创建 aws 安全组并添加到实例
- javascript - 为什么 v-bind 参数不能引用对象中的变量?
- algorithm - 差异算法:根据实际成绩单获取口语音节的时间戳