activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <>
Subject Re: Network Connector too slow when receive high rate persistent message
Date Tue, 31 Jan 2017 14:03:43 GMT
Do either of your broker logs show Producer Flow Control kicking in?

And for both of you, is performance normal if you have just a single broker
(or all clients on the same broker, which is the same thing)?

On Jan 30, 2017 5:36 PM, "Adam Whitney" <> wrote:

I'm having a similar issue with 5.13.3. We have 3 brokers configured as a
grid network (each connected to the other 2). For the clients, we are using
JmsTemplate to produce messages from 2 hosts ... and
DefaultMessageListenerContainer to consume from another 2 hosts. Each
consumer client is a single tomcat instance with 50 consumer threads on a
single connection to the broker. This means that one of the 3 brokers is
always left with now "real" consumer clients - only "network" consumers.

When we send 570 messages per second we see messages start to queue on one
of the brokers ... invariably, the broker that starts to build up it's queue
is the one that has at least one producer and no "real" client consumers
(i.e. only "network" consumers).

If we stop 2 of the brokers and just have a single broker with 2 producers
and 2 consumers then we don't see any queueing on that broker even at 570
tps the single broker and "real" client consumers can keep up with the
messages. This seems to indicate that it is the network consumers that are
not able to keep up.

FWIW, my brokers are using "pure java" version of levelDB:
    <levelDB directory="${}/leveldb"/>

And here's our network connector config:
            <networkConnector name="mqpQueueConnector"

                              messageTTL="-1" conduitSubscriptions="false"
duplex="false" consumerPriorityBase="0"

View this message in context: http://activemq.2283324.n4.
Sent from the ActiveMQ - User mailing list archive at

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message