JBM 2 Consumer flow control.

[ataylor]

Here is the problem.

I have 1 MessageProducer and 1 MessageListener.
The MessageProducer sends messages as fast as it can to a queue and the listener receives from the queue. At the point that the producer stops sending messages the listener stops receiving even if the all the messages haven't been delivered. If i disable consumer flow control (by setting to -1) then this does not happen.

The consumer will start receiving messages again once there are more available tokens, tokens are added on receipt of a message. however it looks like even tho delivery is prompted on receipt of a message the delivery of messages isn't restarted.

I'll investigate further!

[timfox]

When the consumer frees up some messages on the client side it will send a changeRate, which should cause delivery to be prompted on the queue.

See ServerConsumerEndpoint::changeRate()

[ataylor]

See ServerConsumerEndpoint::changeRate()

is this 2.0 as this class doesn't exist anymore?

[timfox]

ServerConsumerImpl::receiveTokens in JBM 2.0

[ataylor]

yeah ive been looking at this, i have noticed that promptDelivery is called in a a different thread i.e.

public void promptDelivery(final Queue queue)
 {
 // TODO - do we really need to prompt on a different thread?
 executor.execute(new Runnable()
 {
 public void run()
 {
 queue.deliver();
 }
 });
 }

if i change this the problem goes away, maybe this is causing a race condition!

[timfox]

IIRC this is called on a different thread to avoid a deadlock condition.

I would try and find out why it's not actually being executed - has the executor shutdown or maybe it's queue is full?