i solved my project with AMQ, but the problem is still there without my project. in my project i have 3 AMQs. one is the TOP, another two are children of the TOP.and two children do NOT have communication.so i just connect the TOP to two children, and two children connect to TOP without two children connect to each other. i can get and send the messages in my assume. but before i use AMQ in my project. i test the 3 AMQs, i connect 3 with each other, NO TOP NODE. and i use dynamicallyIncludedDestinations and excludedDestinations to filter the message. each of 3 get a excludedDestinations queue. but problem occured. this is my experiment: 3 machines IPs: 192.9.105.140-192.9.105.142 3 AMQs one each of them. and exclusive queue R.01007040000000000000-R.01007042000000000000 i use 3 clients send messages to each 3 AMQs with the same queue named R.01007040000000000000. i assume i can get all the messages just from one AMQ which have the excludedDestinations with the queue R.01007040000000000000 and the IP is 192.9.105.140. the result is i could get messages from another two AMQs in pratical. for example: one client send 10 messages to 192.9.105.141's queue R.01007040000000000000. 192.9.105.141 have one excludedDestinations named R.01007041000000000000 (NOT queue R.01007040000000000000). so i thought all the messages should forward to another two AMQs, 192.9.105.142 should forward again because its exclusive queue is R.01007042000000000000. in pratical, i can get messages from 192.9.105.142's queue R.01007040000000000000. and that not i want...
these the XML content ========================192.9.105.140==================================== <beans> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> <broker brokerName="MQ01007040000000000000" useJmx="false" persistent="true" xmlns="http://activemq.org/config/1.0";> <persistenceAdapter> <journaledJDBC journalLogFiles="5" dataDirectory="${activemq.base}/activemq-data"/> </persistenceAdapter> <transportConnectors> <transportConnector name="TCP01007040000000000000" uri="tcp://localhost:61616" /> </transportConnectors> <networkConnectors> <networkConnector name="CONNECT010070400000000000000" failover="false" uri="static://(tcp://192.9.105.141:61616,tcp://192.9.105.142:61616)"> <excludedDestinations> <queue physicalName="R.01007040000000000000"/> </excludedDestinations> </networkConnector> </networkConnectors> </broker> </beans> ========================192.9.105.141==================================== <beans> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> <broker brokerName="MQ01007041000000000000" useJmx="false" persistent="true" xmlns="http://activemq.org/config/1.0";> <persistenceAdapter> <journaledJDBC journalLogFiles="5" dataDirectory="${activemq.base}/activemq-data"/> </persistenceAdapter> <transportConnectors> <transportConnector name="TCP01007041000000000000" uri="tcp://localhost:61616" /> </transportConnectors> <networkConnectors> <networkConnector name="CONNECT010070410000000000000" failover="false" uri="static://(tcp://192.9.105.140:61616,tcp://192.9.105.142:61616)"> <excludedDestinations> <queue physicalName="R.01007041000000000000"/> </excludedDestinations> </networkConnector> </networkConnectors> </broker> </beans> ========================192.9.105.142==================================== <beans> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> <broker brokerName="MQ01007042000000000000" useJmx="false" persistent="true" xmlns="http://activemq.org/config/1.0";> <persistenceAdapter> <journaledJDBC journalLogFiles="5" dataDirectory="${activemq.base}/activemq-data"/> </persistenceAdapter> <transportConnectors> <transportConnector name="TCP01007042000000000000" uri="tcp://localhost:61616" /> </transportConnectors> <networkConnectors> <networkConnector name="CONNECT010070420000000000000" failover="false" uri="static://(tcp://192.9.105.140:61616,tcp://192.9.105.141:61616)"> <excludedDestinations> <queue physicalName="R.01007042000000000000"/> </excludedDestinations> </networkConnector> </networkConnectors> </broker> </beans> ============================END===================================== thank you again. rajdavies wrote: > > Can you send the actual xml configuration for all three brokers ? > On Dec 21, 2007, at 5:04 AM, Lephix wrote: > -- View this message in context: http://www.nabble.com/how-to-set-the-message-distination-of-Networks-of-Broker.-tp14436327s2354p14455303.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
