with prefetch=0 it should work ok as this will force a receive() to poke the
broker rather than depending on async delivery.
change:
queue = session.createQueue("TEST");
to
queue = session.createQueue("TEST?consumer.prefetchSize=0");
On 4 February 2010 11:33, colincrist <colincr...@hermesjms.com> wrote:
>
> See attached unit test. The receiveOneMessageUsingSessionListener() test
> hangs.
>
> Tests all work okay with, for example, Tibco EMS.
>
> http://old.nabble.com/file/p27451302/PublicTestMessageExchange.java
> PublicTestMessageExchange.java
>
> Regards,
>
> Colin.
> --
> View this message in context:
> http://old.nabble.com/Session.setMessageListener-not-working-in-5.3.2-tp27451302p27451302.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
http://blog.garytully.com
Open Source Integration
http://fusesource.com
