Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: neutral (nike.apache.org: local policy)
Date: Tue, 15 May 2012 19:22:56 -0700 (PDT)
From: Samslara <samslara@yahoo.com>
To: users@activemq.apache.org
Message-ID: <1337134976493-4639822.post@n4.nabble.com>
Subject: duplex and producer flow control
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hello,
  I'm having an issue when sending a number of messages that starts producer
flow control between two brokers and when the networkConnector between the
two is setup as duplex.  The setup I have is I have two brokers, A and B.  I
also have two consumers on B subscribed to two topics, topic1 and topic2.  I
then have two producers on A which are publishing on topic1 and topic2.  So
when I startup the consumer on B on topic1 and have it consume messages
slowly, and then I produce a large number of messages to topic1 on A so that
producer flow control is triggered and the producer on A is held back from
sending more because of this.  I then start the consumer on topic2 on B and
have it consume quickly.  When I produce to topic2 on A the messages do not
flow like they should.  Rather they hold on the networkConnector until 5
messages make it to topic1 and then 5 messages all get sent right away to
topic2.  It seems like this burst of messages always matches the
prefetchSize of the networkConnector.  Also when I stop the consumer on
topic1 all the messages being held back for topic1 gets send right away and
topic1 receives messages like normal.  This problematic behavior goes away
when duplex="false".  Can anyone provide me with any insight into why this
is happening and how to get around it?

P:topic1 -\               /-> C:topic1 (slow)
P:topic2 --> A --> B --> C:topic2 (fast)

networkConnector definition:
<networkConnectors>
  <networkConnector uri="static:(tcp://localhost:61617)"
    duplex="true"
    conduitSubscriptions="true"
    dynamicOnly="true"
    networkTTL="7"
    suppressDuplicateQueueSubscriptions="true"
    decreaseNetworkConsumerPriority="true"
    alwaysSyncSend="true"
    bridgeTempDestinations="true" 
	prefetchSize="5" />
</networkConnectors>

--
View this message in context: http://activemq.2283324.n4.nabble.com/duplex-and-producer-flow-control-tp4639822.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.