前两天遇到个问题,如果一个queue里堵塞了1000+以上的message,然后启动多个consumers,发现新启动的consumer没有去处理原来堵塞的message,只会处理新进来的message。经过查找发现,原来MQ默认的prefetch limit是1000,也就是说,当一个queue堵塞了1000个message,当有一个consumer运行的时候,这1000个message就会直接分配给这一个consumer,我们可以通过设置这个prefetch limit来控制它,简单的方法就是

在new stomp的时候传个header进去,比如

$stomp = new Stomp(tcp://localhost:61613);
$headers['activemq.prefetchSize'] = 1;
$stomp->subscribe(queuename, $headers);

相关文档

http://activemq.apache.org/what-is-the-prefetch-limit-for.html

http://activemq.apache.org/stomp.html

ActiviteMQ 对于Consumers pending的限制问题相关推荐

  1. activemq 管理后台 Number Of Pending Messages、Number Of Consumers、Messages Enqueued、Messages Dequeued的意思

    Number Of Consumers :表示消费者数量: Number Of Pending Messages :等待消费的消息,这个是当前未出队列的数量: Messages Enqueued :进 ...

  2. Ambari安装之部署 (Metrics Collector和 Metrics Monitor) Install Pending ...问题

    问题详细描述如下:  Metrics Collector的解决办法 正在重新安装 Metrics  Monitor的解决办法 Metrics Collector和 Metrics Monitor 的I ...

  3. hudson pending - Waiting for next available executor

    领导要求使用hudson 搭建CI测试环境. 安装的hudson 版本是:3.0.1-b2 刚开始可以构建项目,有一段时间没研究.过了一段时间之后,在使用hudson 构建项目时,报错: pendin ...

  4. BACKUP PENDING状态的解除

    1.数据库比较大的时候 [db2inst1@db2serv1 ~]$ db2 connect to YXDB SQL1116N  A connection to or activation of da ...

  5. 【B站视频笔记】linux 进程间通信(ipc)信号(软中断信号)signal库函数、可靠信号和不可靠信号、信号集sigprocmask(信号掩码、信号递达Delivery、信号未决Pending)

    [视频教程]Linux信号详解(可靠信号.不可靠信号.阻塞信号.信号处理函数) [博文]Linux信号 文章目录 背景 课程笔记 一.如何让程序在后台运行 1.加"&"符号 ...

  6. 机器人运动规划调研(pending)

    文章目录 前言 发展历程 通用运动规划方法 基于自由空间 Cfree几何构造的规划方法 可视图法 前言 阅读移动机器人运动规划研究综述心得 总结一下,机器人运动规划的发展历程,算法和思路. 搜索策略和 ...

  7. 1.12.Flink Kafka-Connector详解、Consumer消费策略设置、动态加载Topic、Consumers Offset 自动提交、Producer、容错等

    1.12.Flink Kafka-Connector详解 1.12.1.Kafka Consumer消费策略设置 1.12.2.Kafka Consumer的容错 1.12.3.动态加载Topic 1 ...

  8. Oracle 11g 数据统计量Pending处理

    在CBO时代,SQL语句的执行计划完全依赖于在数据字典中保存的统计量信息和优化器Optimizer的计算公式参数.从9i开始到现在的11gR2,我们说CBO优化器已经很成熟和完善.在通常情况下,我们的 ...

  9. Sharepoint client model 中出现Cannot invoke HTTP DAV request. There is a pending query 的解决办法...

    由于近期在某项目中使用sharepoint client 对象模型做项目 在sharepoint 2010环境下正常,但迁移到sharepoint 2013后报错,提示如下 Cannot invoke ...

最新文章

  1. 11月第三周.COM增13.8万 ×××域名.XXX减9个
  2. FAGLFLEXA 表和 BSEG 表有什么区别
  3. react-navigation设置navigationOptions中Static中使用 this 的方法
  4. C宏定义-SWAP的妙用
  5. 偶也要去上海Tech一把了
  6. 剑指Offer - 面试题57 - II. 和为s的连续正数序列(滑动窗口)
  7. java 旅行家的预算_洛谷 P1016 旅行家的预算 Java解法
  8. PE文件磁盘与内存映像结构图
  9. OpenCV计算机视觉实战(Python版)_006边缘检测
  10. cpu out of order, 性能优化
  11. access课程均不及格_Access 应用基础—查询设计
  12. Ventoy+WePE 装机教程(装PVE+ESXI等,不用单独费一个U盘)
  13. 错觉图片生成实验 - 闪现的绿点
  14. upnp+摄相头捕捉服务器端程序
  15. windows7蓝牙怎么打开_windwos7系统怎么添加蓝牙鼠标
  16. 用shell脚本批量删除文件名后缀
  17. 程序员跳槽和面试,猎头不会告诉你的那些事儿
  18. unity android 触屏,Unity 移动端触摸屏操作
  19. Combined Margin loss人脸识别训练笔记
  20. echarts动态渲染柱状图背景颜色以及顶部数值

热门文章

  1. ubantu 安装显卡
  2. js的for循环中return可以跳出循环,而使用forEach等不可以跳出循环
  3. Word中的滚动文本框是如何制作(可以)
  4. react常用生命周期流程图
  5. kali firefox gah. your tab just crashed. 更新Firefox
  6. 无间狱无服务器信息,无间狱打不动了,分享一些想法(不开99流),多图
  7. Python 算法训练之摩斯电码
  8. 找参考图的同志们看过来,分享几个建模参考网站给你们。再不用愁啦
  9. 报错: java.lang.IllegalArgumentException: mapper [categoryName] of different type, current_type [text]
  10. OpenCV mat类实现水平投影和垂直投影