[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    Network of brokers
From:       Mathulan <mathulan () gmail ! com>
Date:       2007-02-27 16:15:02
Message-ID: 9185505.post () talk ! nabble ! com
[Download RAW message or body]


Hi All,

I am trying to configure set of brokers running distributed over the WAN. 
There are 3 machines devdist01 (Distribution server), devslave01 (slave
server), devpres01 (presentation server).
The communication between brokers are devslave01 -> devdist01 <-> devpres01. 
Basically devslave01 publishes and devdist01 a middleman distributes to
devpres01. 
The queues are statically configured on devdist01 and are automatically
distributed to others on startup. I can also see the bridges are
successfully connected in the log and jconsole. 

Now when the devslave01 publishes a topic it is not received at the
subscriber attached to devpres01. 
I tried attacing a subsciber to devdist01 and it receives. 
It looks to me in the case of devdist01 funtioning are router doesn't work.
Please help to get the configurarion working.

Below is the configuration I am using in all these 3 nodes.

Many thanks,
Kind Regards
Matt





On devdis01

<beans>  
  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  <broker brokerName="devdist01" useJmx="true"
xmlns="http://activemq.org/config/1.0">

    <destinations>
      <queue physicalName="MyQueue" />
      <topic physicalName="MyTopic" />
    </destinations>


    <!-- NOT SET In ActiveMQ 4, you can setup destination policies -->
   

    <persistenceAdapter>
        <journaledJDBC journalLogFiles="5"
dataDirectory="${activemq.base}/activemq-data"/>
    </persistenceAdapter>

    <transportConnectors>   
       <transportConnector name="openwire"
uri="tcp://localhost:61616?trace=true"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
    </transportConnectors>
    
    <networkConnectors>
      <networkConnector name="devdist01-devslave01"
                        uri="static://(tcp://devslave01:61616)"
                        dynamicOnly="false"
                        networkTTL="99"
                        bridgeTempDestinations="true"
                        failover="true"
                        conduitSubscriptions="false">
        </networkConnector>

      <networkConnector name="devdist01-devpres01"
                        uri="static://(tcp://devpres01:61616)"
                        dynamicOnly="false"
                        networkTTL="99"
                        bridgeTempDestinations="true"
                        failover="true"
                        conduitSubscriptions="false">
      </networkConnector>

    </networkConnectors>
  </broker>
  
  
  
 
--------------------------------------------------------------------------------------------------
On devslave01  


  <beans>
  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>  
  <broker brokerName="devslave01" useJmx="true"
xmlns="http://activemq.org/config/1.0">
  <!-- NOT USED Use the following to set the broker memory limit  -->
  <!-- NOT USED Use the following to configure how ActiveMQ is exposed in
JMX -->
  <!-- NOT USED In ActiveMQ 4, you can setup destination policies -->
    


    <persistenceAdapter>
        <journaledJDBC journalLogFiles="5"
dataDirectory="${activemq.base}/activemq-data"/>
    </persistenceAdapter>

    <transportConnectors>
       <transportConnector name="openwire"
uri="tcp://localhost:61616?trace=true"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
    </transportConnectors>

    
    <networkConnectors>
        <networkConnector name="devslave01-devdist01"
                        uri="static://(tcp://devdist01:61616)"
                        dynamicOnly="false"
                        networkTTL="99"
                        bridgeTempDestinations="true"
                        failover="true"
                        conduitSubscriptions="false">
       </networkConnector>

    </networkConnectors>

  </broker>

---------------------------------------------------------------------------------------

On devpres01

<beans>
  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  <broker brokerName="devpres01" useJmx="true"
xmlns="http://activemq.org/config/1.0">
  <!-- NOT USED  Use the following to set the broker memory limit -->
  <!-- NOT USED Use the following to configure how ActiveMQ is exposed in
JMX -->
  <!-- NOT USED In ActiveMQ 4, you can setup destination policies -->
  
    <persistenceAdapter>
        <journaledJDBC journalLogFiles="5"
dataDirectory="${activemq.base}/activemq-data"/>
    </persistenceAdapter>

    <transportConnectors>  
       <transportConnector name="openwire"
uri="tcp://localhost:61616?trace=true"/>
       <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
       <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
    </transportConnectors>

    <networkConnectors>
    	<networkConnector name="devpres01-devdist01"
                        uri="static://(tcp://devdist01:61616)"
                        dynamicOnly="false"
                        networkTTL="99"
                        bridgeTempDestinations="true"
                        failover="true"
                        conduitSubscriptions="false">
      	</networkConnector>

    </networkConnectors>

  </broker>
-- 
View this message in context: http://www.nabble.com/Network-of-brokers-tf3302072s2354.html#a9185505
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


[prev in list] [next in list] [prev in thread] [next in thread]