Thanks a lot, this is great!!! In the standard amq distribution there is this all-including jar called incubator-activemq-4.0.1.jar.
I cannot make maven build this. I use the following command, which creates all target jars but not the one I need. mvn -Dmaven.test.skip=true package -----Original Message----- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Thursday, August 10, 2006 11:49 AM To: [email protected] Subject: Re: Pulling consumer design On 8/10/06, Pesochinskiy, Vadim (MSCIBARRA) <[EMAIL PROTECTED]> wrote: > James, > > One way to implement this, which I think will fit with current design > is to introduce a MessagePullCommand, which informs the broker that > consumer is ready to accept next message. When broker get this request > it dispatches one message to this consumer. What do you think about > this? Good idea. Actually if you check SVN trunk I committed something like this about an hour ago :) I'm just committing a test case that shows it working as I type (ZeroPrefetchConsumerTest) :) So basically prefetch of zero can be supported for synchronous consumers (where receive(long) or receive() is called). We throw an exception if you try and use it for async subscription (consumer.setMessageListener()). The one issue with the current implementation is that the receive(timeout) must wait long enough for a message to arrive from the broker; otherwise the method may return but a message is dispatched just shortly afterwards. So provided you give a reasonably large receive(timeout) then it should do what you need. -- James ------- http://radio.weblogs.com/0112098/ -------------------------------------------------------- NOTICE: If received in error, please destroy and notify sender. Sender does not intend to waive confidentiality or privilege. Use of this email is prohibited when received in error.
