rabbitmq - Fanout exchange behaving as Direct exchange in Spring AMQP -


i facing issue while using rabbitmq in fanout exchange due unknown reason behaving direct exchange.

i using following binding , queue configuration

<bean id="testfanout"         class="com.test">         <constructor-arg name="exchange" ref="test" />         <constructor-arg name="routingkey" value="test" />         <constructor-arg name="queue" value="testq" />         <constructor-arg name="template">             <bean class="org.springframework.amqp.rabbit.core.rabbittemplate">                 <constructor-arg ref="connectionfactory" />             </bean>         </constructor-arg>         <constructor-arg value="true"/>     </bean>  <rabbit:fanout-exchange name="test" id="test">         <rabbit:bindings>             <rabbit:binding queue="test"/>         </rabbit:bindings> </rabbit:fanout-exchange>

now have same code listening same testq on 2 different vm's somehow message send 1 vm listener using round robin algorithm

sender code

channel = ...   rabbittemplate template = null;             if(channel != null){                 template = channel.gettemplate();                 if(template != null){                     template.setqueue(channel.getqueue());                     template.setexchange(channel.getexchange().getname());                     template.convertandsend(channel.getroutingkey(), txtmsg);

the routing key ignored fanout exchange.

are sure it's fanout exchange in rabbitmq? don't see rabbitadmin in configuration (which attempt declare exchange , binding).

look @ exchange in rabbitmq ui , check type/bindings.


Comments

Post a Comment

Popular posts from this blog

java - WARN : org.springframework.web.servlet.PageNotFound - No mapping found for HTTP request with URI [/board/] in DispatcherServlet with name 'appServlet' -

this question has answer here: why spring mvc respond 404 , report “no mapping found http request uri […] in dispatcherservlet”? 3 answers i trying making simple bbs i'm encountering following error, warn : org.springframework.web.servlet.pagenotfound - no mapping found http request uri [/board/] in dispatcherservlet name 'appservlet' i have tried solve error many times, have failed. how can solve error? here web.xml, controllerand , servlet-context. my web.xml <?xml version="1.0" encoding="utf-8"?> <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xsi:schemalocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"> <filter> <filter-nam...
Read more

html - Outlook 2010 Anchor (url/address/link) -

i'm trying link specific pdf page msoutlook'10 or msword'10, #page=... anchor particularly useful , works fine elsewhere. unfortunately when click [ctr-k] in outlook or winword, links re-formatted assuming unc path. pdf file located on shared drive. using "file:" prefix links open pdf in adobe reader (outside of browser), , "http:" open inside browser. issue seem need open in browser "file:" prefix in order anchor work. know anchors work inside browser. outlook uses windows/explorer default program (based on file extension) seems open in adobe reader neglecting anchor. is aware of solution, link specific page or bookmark of shared-pdf ms outlook and/or winword link? common references: mailermailer.com/...anchor-tags-html-emails campaignmonitor.com/...anchor-links-in-email-newsletters/ stackoverflow.com/...anchor-in-pdf-document
Read more

android - How to create dynamically Fragment pager adapter -

i unable create dynamic layout each tabs, able create tabs dynamically constructor(public mypageradapter(fragmentmanager fm , int nooftabs)), coudn't inflate view each tabs creating each fragment should dyanmic. public class mypageradapter extends fragmentpageradapter { private final string[] titles = { "categories", "home", "top paid", "top free", "top grossing", "top new paid", "top new free", "trending" }; int nooftabs; **public mypageradapter(fragmentmanager fm , int nooftabs) { super(fm); this.nooftabs = nooftabs; }** /*public mypageradapter(fragmentmanager fm) { super(fm); }*/ @override public charsequence getpagetitle(int position) { return titles[position]; } @override public int getcount() { ...
Read more