activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Tully (JIRA)" <>
Subject [jira] [Created] (AMQ-4235) Broker configured prefetch values are lost on failover reconnect
Date Fri, 21 Dec 2012 14:37:12 GMT
Gary Tully created AMQ-4235:

             Summary: Broker configured prefetch values are lost on failover reconnect
                 Key: AMQ-4235
             Project: ActiveMQ
          Issue Type: Bug
          Components: Broker
    Affects Versions: 5.7.0, 5.6.0
            Reporter: Gary Tully
            Assignee: Gary Tully
             Fix For: 5.8.0

two brokers configured with the following policy:

 <policyEntry topic="FOO.>" topicPrefetch="10" />

My consumer will failover to the other broker, if it is no longer there:

            ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user,
password, "failover:tcp://xx:61666,tcp://xx:61667");

When this subscription becomes active ( ant consumer -Dsubject=FOO.TEST -Dtopic=true -Dmax=100),
I can see in jconsole that prefetch limit is indeed 10. When I kill the  broker on 61666,
the consumer failsover to 61667. Unfortunately, the prefetch limit has now changed to 32766.

If one configures the consumer to set the prefetch limit:

destination = session.createTopic(subject +"?consumer.prefetchSize=20");

It works consistently, but not having control of consumers, it needs to be configurable broker

This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see:

View raw message