activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tomerb <tom...@waze.com>
Subject network of brokers reduced capacity
Date Sun, 29 Jan 2012 15:06:48 GMT
I have configured an ActiveMQ network of brokers, which seems to work fine,
function wise.
However, the capacity of messages traveling from a producer which is
connectes to broker a, to a consumer which is connected to broker b, is
about three times worse, then for producer/consumer connected to the same
broker.
This seems odd to me, as I was under the impression that once broker a,
passes the message to broker b, it is a delivered message (from broker a
POV), so there should be no capacity decrease.

here is my activemq.xml configuration:

<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.apache.org/schema/core"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd">

<broker xmlns="http://activemq.apache.org/schema/core"
brokerName="localhost" dataDirectory="${activemq.base}/data"
destroyApplicationContextOnStop="true" persistent="false">

    <destinationPolicy>
        <policyMap>
          <policyEntries>
            <policyEntry topic=">" producerFlowControl="true"
memoryLimit="5mb">
              <pendingSubscriberPolicy>
                <vmCursor />
              </pendingSubscriberPolicy>
            </policyEntry>
            <policyEntry queue=">" producerFlowControl="true"
memoryLimit="50mb">

              
            </policyEntry>
          </policyEntries>
        </policyMap>
    </destinationPolicy> 





    
    <managementContext>
        <managementContext createConnector="false"/>
    </managementContext>

    <networkConnectors>
        <networkConnector name="tomer-amq-test1"
uri="static:(tcp://tomer-amq-test1:61616)" networkTTL="3"/>
    </networkConnectors>


    
    <persistenceAdapter>
        <kahaDB directory="${activemq.base}/data/kahadb"/>
    </persistenceAdapter>


      


    
    <transportConnectors>
        <transportConnector name="tomer-amq-test2"
uri="tcp://0.0.0.0:61616"/>
    </transportConnectors>

</broker>


<import resource="jetty.xml"/>

</beans>


Am I wrong?
Is there some special configuration I have to employ?
can someone shed some light on the flow?

Tx Tomer


--
View this message in context: http://activemq.2283324.n4.nabble.com/network-of-brokers-reduced-capacity-tp4338401p4338401.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message