Network of brokers, idle consumers

[mbordash]

Hi,

We're running ActiveMQ 5.6.0. We have 3 brokers operating in a static
network in our test environment.  Here's the current scenario. We have 6
consumers randomly connecting to the 3 brokers. One broker has 3 consumers,
the second has 2, the 3rd has 1. When we pile on message to the queue, we're
seeing that messages are backlogging on the 3rd broker with 1 consumer, the
other two brokers aren't given any of the backlog and the remaining 5
consumers are idle. 

Below you'll find our configuration for all one of our brokers
(dev.queue01), the other 2 are similar with the proper changes for the
static hostnames.  

I would expect that messages would be automatically distributed to the other
brokers for consumption by the idle consumers. Please tell me if I've missed
something in my description of the problem.  Thanks in advance for any
guidance.

<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";>

    <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>file:${activemq.conf}/credentials.properties</value>
        </property>
    </bean>

    <broker xmlns="http://activemq.apache.org/schema/core";
brokerName="prd.queue01" dataDirectory="${activemq.data}">

        <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" producerFlowControl="false"
memoryLimit="1mb">
                  <pendingSubscriberPolicy>
                    <vmCursor />
                  </pendingSubscriberPolicy>
                </policyEntry>
                <policyEntry queue=">" producerFlowControl="false"
memoryLimit="64mb" optimizedDispatch="true" enableAudit="false"
prioritizedMessages="true">
                  <networkBridgeFilterFactory>
                    <conditionalNetworkBridgeFilterFactory
replayWhenNoConsumers="true" />
                  </networkBridgeFilterFactory>
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy>

        <managementContext>
            <managementContext createConnector="true"/>
        </managementContext>

        <persistenceAdapter>
            <amqPersistenceAdapter directory="${activemq.data}/data/amqdb"/>
        </persistenceAdapter>

          <systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit="256 mb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="750 gb"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="750 gb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>
        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"
updateClusterClients="true" updateClusterClientsOnRemove="true"
rebalanceClusterClients="true"/>
        </transportConnectors>

        <networkConnectors>
          <networkConnector
uri="static:(tcp://dev.queue02:61616,tcp://dev.queue03:61616)"
name="queues_only" conduitSubscriptions="false"
decreaseNetworkConsumerPriority="false" networkTTL="4">
          <dynamicallyIncludedDestinations>
            <queue physicalName=">"/>
          </dynamicallyIncludedDestinations>
          <excludedDestinations>
            <topic physicalName=">"/>
          </excludedDestinations>
        </networkConnector>
    </networkConnectors>


    </broker>
    <import resource="jetty.xml"/>

</beans>
 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Network-of-brokers-idle-consumers-tp4660558.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.