activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lephix <lep...@163.com>
Subject Re: how to set the message distination of Networks of Broker.
Date Fri, 21 Dec 2007 13:19:03 GMT

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.


Mime
View raw message