You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@activemq.apache.org by kotyara85 <ko...@gmail.com> on 2019/03/13 20:09:39 UTC

ActiveMQ Master-Slave brokers - Puppet mcollective

Hi guys,
I set up activemq based on this document
https://puppet.com/docs/mcollective/current/deploy/middleware/activemq.html

Everything worked fine until we got 6000 more servers subscribed.

Sys memory:


brokers config

transport = 0.0.0.0:61616?jms.prefetchPolicy.all=100000&amp;

    <bean id="prefetchPolicy"
class="org.apache.activemq.ActiveMQPrefetchPolicy">
         <property name="queuePrefetch" value="100000" />
    </bean>



        <systemUsage>
            <systemUsage sendFailIfNoSpace="true">
                <memoryUsage>
                    <memoryUsage limit="2 gb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="5 gb" name="foo"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="1 gb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>


I see the next error after which master broker & slaves cannot communicate
to each other:
2019-03-13 13:03:49,078 | WARN  | TopicSubscription:
consumer=broker1->broker2-38486-1552507411577-12:1:1:1, destinations=6,
dispatched=1000, delivered=0, matched=1001, discarded=0: has twice its
prefetch limit pending, without an ack; it appears to be slow |
org.apache.activemq.broker.region.TopicSubscription | ActiveMQ Transport:
ssl:///192.168.12.6:45626

Is there any workarounds around this?


Thanks





--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html