paulwong

          ACTIVEMQ設置預取消息數目

          當ACTIVEMQ的某個QUEUE有多個消費者,為避免某個消息者取了更多個消息處理,而造成其他消費者無消息可處理的情況,可以設置每個消費者不預取消息,即每個消費者消費完單個消息后,再去取消息,這樣其他消費者就能平均的有消息可處理。


          https://stackoverflow.com/questions/35928089/activemq-how-to-prevent-message-from-going-to-dispatched-queue


          設置方法,在CONNECT STRING中設置:
          tcp://localhost:61616?jms.prefetchPolicy.all=0 

          tcp://localhost:61616?jms.prefetchPolicy.queuePrefetch=0 

          queue = new ActiveMQQueue("TEST.QUEUE?consumer.prefetchSize=10"); 
          consumer = session.createConsumer(queue);

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

          posted on 2019-10-31 11:28 paulwong 閱讀(833) 評論(0)  編輯  收藏 所屬分類: JMS

          主站蜘蛛池模板: 茶陵县| 栾城县| 龙岩市| 新干县| 县级市| 洱源县| 普宁市| 北海市| 台中县| 上犹县| 内乡县| 兰州市| 区。| 司法| 娄烦县| 密山市| 灵宝市| 上虞市| 商水县| 永州市| 颍上县| 安平县| 米脂县| 金川县| 寿光市| 长子县| 普定县| 枝江市| 雷州市| 巴林左旗| 出国| 合山市| 米泉市| 舟山市| 荣昌县| 黔西县| 军事| 锦州市| 广饶县| 平江县| 建始县|