[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-users
Subject:    setProducerWindowSize inhibits propagation of ResAllocEx + producer
From:       AndreiD <theonlyandrei () gmail ! com>
Date:       2011-08-31 22:07:21
Message-ID: 1314828440986-3782348.post () n4 ! nabble ! com
[Download RAW message or body]

I've been experimenting with various flow control scenarios and all the
"standard" scenarios worked as expected (sync/async sends with
sendFailIfNoSpace set/not on the broker side) - I'm seeing
blocking/AllocationException/nothing in the client depending on the
scenario.

What I really want is what the producerWindowSize promises - async sends +
flow control.
But if I set the producerWindowSize the producer blocks (after a few msgs)
and then it stays blocked even after a consumer successfully gets the
messages successfully received by broker.

My questions are:

1.Given my broker flow control settings, why does the producer block in the
first place? I've set the sendFailIfNoSpace=true in the broker, so I'm
expecting the ResourceAllocationException (which I do see on the broker
console) to be propagated to the client, once the producer window size limit
is reached and the broker throws the ex.

2.Why doesn't the producer unblock once a consumer consumes the msgs
successfully stored in the broker?

I'm using the prod/cons from the 5.4.2 examples, with 2 ProducerTool tweaks:
-connectionFactory.setProducerWindowSize(5000);
-I explicitely set DeliveryMode to NON_PERSISTENT

My broker config:
....
<policyEntry queue="TEST.FOO"
                   producerFlowControl="true"
                   memoryLimit="50kb">
      <pendingQueuePolicy>
           <vmQueueCursor />  
      </pendingQueuePolicy>
</policyEntry>
....
<systemUsage>
    <systemUsage sendFailIfNoSpace="true">
<systemUsage>


Thanks in advance!

--
View this message in context: \
http://activemq.2283324.n4.nabble.com/setProducerWindowSize-inhibits-propagation-of-ResAllocEx-producer-stays-forever-blocked-once-it-blocs-tp3782348p3782348.html
 Sent from the ActiveMQ - User mailing list archive at Nabble.com.


[prev in list] [next in list] [prev in thread] [next in thread]