activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <>
Subject Re: Problem With Producer Flow Control?
Date Thu, 28 May 2009 08:23:47 GMT
Hi Joe,

I think problem is that your thread is blocked on producer send(), so no
matter sessions and connections nothing else could be done until it is

Dejan Bosanac

Open Source Integration -
ActiveMQ in Action -
Blog -

On Wed, May 27, 2009 at 5:22 PM, Joe Fernandez <> wrote:

> I am running some exception tests against AMQ 5.2 that force producer
> flow-control to occur and have a question regarding sessions and flow
> control. Here's my set up.
> Te test app, which is using an 'embedded' broker, has an object (Ob1) that
> implements MessageListener. Ob1 creates two AMQ connections (con1, con2), a
> session (s1) from con1, a session (s2) from con2, a producer (p1) from s1
> and a consumer (c2) from s2. The c2 consumer is assigned Ob1's onMessage()
> method via c2.setMessageListener(this). The onMessage() method has a built
> in delay to simulate a slow consumer. The ack mode is set to
> AUTO_ACKNOWLEDGE. The producer and consumer are producing to and consuming
> from the same destination, respectively. The message that is produced by p1
> is a relatively small text message; maybe 30 characters in length.
> When the test starts, p1 floods the queue with messages and producer flow
> control kicks in, at which point p1 gets blocked. However, the calls to the
> onMessage method also stop so the test hangs.  Given that p1 and c2 are
> operating within their own separate connections and sessions, shouldn't the
> AMQ client code continue to call the onMessage method with messages even
> when p1 gets placed in flow control mode?
> Side note: if I place con2, s2, and c2 in a separate thread object, then
> the
> test runs just fine. That is, the p1 producer goes in and out of flow
> control as c2's onMessage continues to get called.
> Thanks,
> Joe
> --
> View this message in context:
> Sent from the ActiveMQ - User mailing list archive at

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