pbootcms网站模板|日韩1区2区|织梦模板||网站源码|日韩1区2区|jquery建站特效-html5模板网

添加多個(gè)偵聽器將偵聽不同的 RabbitMQ 隊(duì)列不起作

Adding multiple listeners which will listen to different RabbitMQ queue not working(添加多個(gè)偵聽器將偵聽不同的 RabbitMQ 隊(duì)列不起作用)
本文介紹了添加多個(gè)偵聽器將偵聽不同的 RabbitMQ 隊(duì)列不起作用的處理方法,對(duì)大家解決問(wèn)題具有一定的參考價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧!

問(wèn)題描述

限時(shí)送ChatGPT賬號(hào)..

我有以下 spring xml 配置

I hava following spring xml configuration

<bean id="connectionFactory"
          class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
 <constructor-arg value="xxxxxxxx"/>
        <property name="username" value="xxxxx"/>
        <property name="password" value="xxxxx"/>
        <property name="channelCacheSize" value="25"/>
        <property name="virtualHost" value="/"/>
        <property name="port" value="3453"/>
 </bean>

 <rabbit:template id="tutorialTemplate" connection-factory="connectionFactory"/>
 <!-- 1st queue -->             
 <rabbit:queue id="veliteQueue" name="ES_queue" durable="true" auto-delete="false" exclusive="false"/>
    
 <rabbit:direct-exchange id="myExchange" durable="true" name="ES_exchange">
     <rabbit:bindings>
        <rabbit:binding queue="veliteQueue" key="logstash"></rabbit:binding>
     </rabbit:bindings>
 </rabbit:direct-exchange>

  <!-- 2nd Queue -->
 <rabbit:queue id="veliteQueue1" name="ES_queue_Temp" durable="true" auto-delete="false" exclusive="false"/> 

  <rabbit:direct-exchange id="myExchange1" durable="true" name="ES_exchange_temp">
    <rabbit:bindings>
        <rabbit:binding queue="ES_queue_Temp" key="logstash_temp"></rabbit:binding>
    </rabbit:bindings>
   </rabbit:direct-exchange> 
   <!-- 2 Listeners for 2 queue's mentioned above --> 
   <bean id="aListener" class="com.vzw.es.cosumer.SpringMessageListener" autowire="byName"/>
<bean id="aListener1" class="com.vzw.es.cosumer.SpringMessageListener1" autowire="byName"/>

<rabbit:listener-container id="myListenerContainer" connection-factory="connectionFactory" acknowledge="auto" prefetch="750" concurrency="1">
    <rabbit:listener ref="aListener" queues="veliteQueue"/>
    <rabbit:listener ref="aListener1" queues="veliteQueue1"/>
</rabbit:listener-container>

現(xiàn)在在我的 Java 代碼中,我有 2 個(gè)監(jiān)聽器類:com.vzw.es.cosumer.SpringMessageListener 和 com.vzw.es.cosumer.SpringMessageListener1.現(xiàn)在,當(dāng)我運(yùn)行我的主類時(shí),只有 1 個(gè)偵聽器的 onMessage 方法被調(diào)用,即 SpringMessageListener1,我確實(shí)從 RabbitMQ 進(jìn)行了檢查,并且兩個(gè)隊(duì)列都有足夠的消息來(lái)消費(fèi).

Now in my Java code I have 2 Listener classes: com.vzw.es.cosumer.SpringMessageListener and com.vzw.es.cosumer.SpringMessageListener1. Now When I am running my main class only 1 listener's onMessage method is getting invoked i.e. SpringMessageListener1, I did check from RabbitMQ prespective and bothe queues have enough messages to consume.

此外,當(dāng)我從 xml SpringMessageListener 注釋掉第二個(gè)隊(duì)列及其偵聽器時(shí),效果也很好.

Also when I comment out the 2nd queue and its listener from xml SpringMessageListener works perfectly.

推薦答案

這是容器解析器的一個(gè)bug,每個(gè)監(jiān)聽器都有自己的容器(命名空間只是一種方便的方式來(lái)指定公共屬性).如果您刪除 id="myListenerContainer",它將起作用 - 因?yàn)槊總€(gè)容器都有一個(gè)(不同的)生成名稱.指定 id 后,兩個(gè) bean 的名稱相同,最后一個(gè)定義替換第一個(gè).

It's a bug in the container parser, each listener gets its own container (the namespace is just a convenient way to specify common attributes). If you remove the id="myListenerContainer", it will work - because each container gets a (different) generated name. With the id specified, both beans get the same name, and the last definition replaces the first.

或者,聲明兩個(gè)單獨(dú)的容器元素,具有不同的 ID,并且每個(gè)元素只有一個(gè)偵聽器.

Alternatively, declare two separate container elements, with different IDs, and each having just one listener.

感謝您找到這個(gè).

請(qǐng)打開 JIRA 問(wèn)題

此問(wèn)題在 1.2.1 版中得到解決.

這篇關(guān)于添加多個(gè)偵聽器將偵聽不同的 RabbitMQ 隊(duì)列不起作用的文章就介紹到這了,希望我們推薦的答案對(duì)大家有所幫助,也希望大家多多支持html5模板網(wǎng)!

【網(wǎng)站聲明】本站部分內(nèi)容來(lái)源于互聯(lián)網(wǎng),旨在幫助大家更快的解決問(wèn)題,如果有圖片或者內(nèi)容侵犯了您的權(quán)益,請(qǐng)聯(lián)系我們刪除處理,感謝您的支持!

相關(guān)文檔推薦

Parsing an ISO 8601 string local date-time as if in UTC(解析 ISO 8601 字符串本地日期時(shí)間,就像在 UTC 中一樣)
How to convert Gregorian string to Gregorian Calendar?(如何將公歷字符串轉(zhuǎn)換為公歷?)
Java: What/where are the maximum and minimum values of a GregorianCalendar?(Java:GregorianCalendar 的最大值和最小值是什么/在哪里?)
Calendar to Date conversion for dates before 15 Oct 1582. Gregorian to Julian calendar switch(1582 年 10 月 15 日之前日期的日歷到日期轉(zhuǎn)換.公歷到儒略歷切換)
java Calendar setFirstDayOfWeek not working(java日歷setFirstDayOfWeek不起作用)
Java: getting current Day of the Week value(Java:獲取當(dāng)前星期幾的值)
主站蜘蛛池模板: 【甲方装饰】合肥工装公司-合肥装修设计公司,专业从事安徽办公室、店面、售楼部、餐饮店、厂房装修设计服务 | 碎石机设备-欧版反击破-欧版颚式破碎机(站)厂家_山东奥凯诺机械 高低温试验箱-模拟高低温试验箱订制-北京普桑达仪器科技有限公司【官网】 | 釜溪印象网络 - Powered by Discuz! | 生物风-销售载体,基因,质粒,ATCC细胞,ATCC菌株等,欢迎购买-百风生物 | 嘉兴泰东园林景观工程有限公司_花箱护栏 | 建筑资质代办-建筑资质转让找上海国信启航 | 2025黄道吉日查询、吉时查询、老黄历查询平台- 黄道吉日查询网 | 发电机价格|发电机组价格|柴油发电机价格|柴油发电机组价格网 | 北京公司注册_代理记账_代办商标注册工商执照-企力宝 | 执业药师报名条件,考试时间,考试真题,报名入口—首页 | 安平县鑫川金属丝网制品有限公司,防风抑尘网,单峰防风抑尘,不锈钢防风抑尘网,铝板防风抑尘网,镀铝锌防风抑尘网 | 伶俐嫂培训学校_月嫂培训班在哪里报名学费是多少_月嫂免费政府培训中心推荐 | 澳门精准正版免费大全,2025新澳门全年免费,新澳天天开奖免费资料大全最新,新澳2025今晚开奖资料,新澳马今天最快最新图库-首页-东莞市傲马网络科技有限公司 | 步进_伺服_行星减速机,微型直流电机,大功率直流电机-淄博冠意传动机械 | 佛山市钱丰金属不锈钢蜂窝板定制厂家|不锈钢装饰线条|不锈钢屏风| 电梯装饰板|不锈钢蜂窝板不锈钢工艺板材厂家佛山市钱丰金属制品有限公司 | 食安观察网| 干粉砂浆设备_干混砂浆生产线_腻子粉加工设备_石膏抹灰砂浆生产成套设备厂家_干粉混合设备_砂子烘干机--郑州铭将机械设备有限公司 | 伺服电机_直流伺服_交流伺服_DD马达_拓达官方网站 | 精密线材测试仪-电线电缆检测仪-苏州欣硕电子科技有限公司 | 哈希余氯测定仪,分光光度计,ph在线监测仪,浊度测定仪,试剂-上海京灿精密机械有限公司 | 中国品牌排名投票_十大品牌榜单_中国著名品牌【中国品牌榜】 | 英超直播_英超免费在线高清直播_英超视频在线观看无插件-24直播网 | B2B网站_B2B免费发布信息网站_B2B企业贸易平台 - 企资网 | 不锈钢电动球阀_气动高压闸阀_旋塞疏水调节阀_全立阀门-来自温州工业阀门巨头企业 | 短信通106短信接口验证码接口群发平台_国际短信接口验证码接口群发平台-速度网络有限公司 | 世纪豪门官网 世纪豪门集成吊顶加盟电话 世纪豪门售后电话 | 创客匠人-让IP变现不走弯路| ALC墙板_ALC轻质隔墙板_隔音防火墙板_轻质隔墙材料-湖北博悦佳 | 药品仓库用除湿机-变电站用防爆空调-油漆房用防爆空调-杭州特奥环保科技有限公司 | 美国HASKEL增压泵-伊莱科elettrotec流量开关-上海方未机械设备有限公司 | 免费网站网址收录网_海企优网站推荐平台 | 折弯机-刨槽机-数控折弯机-数控刨槽机-数控折弯机厂家-深圳豐科机械有限公司 | 青州开防盗门锁-配汽车芯片钥匙-保险箱钥匙-吉祥修锁店 | 江苏南京多语种翻译-专业翻译公司报价-正规商务翻译机构-南京华彦翻译服务有限公司 | B2B网站_B2B免费发布信息网站_B2B企业贸易平台 - 企资网 | 法钢特种钢材(上海)有限公司 - 耐磨钢板、高强度钢板销售加工 阀门智能定位器_电液动执行器_气动执行机构-赫尔法流体技术(北京)有限公司 | ptc_浴霸_大巴_干衣机_呼吸机_毛巾架_电动车加热器-上海帕克 | 实体店商新零售|微赢|波后|波后合作|微赢集团 | 北京网站建设-企业网站建设-建站公司-做网站-北京良言多米网络公司 | 广东护栏厂家-广州护栏网厂家-广东省安麦斯交通设施有限公司 | 没斑啦-专业的祛斑美白嫩肤知识网站-去斑经验分享 |