Hi, Could you perhaps explain a bit more briefly what you mean by "capacity decrease"? How do you measure the decrease?
Torsten Mielke tors...@fusesource.com tmie...@blogspot.com On Jan 29, 2012, at 4:06 PM, tomerb wrote: > 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.
