I thought of a hack for this problem (see my code above for original code).
It's not great but it kicks in the listener and doesn't lose messages:

 // lets create a consumer and producer
 IMessageConsumer consumer = session.CreateConsumer(destination); 
 consumer.Listener += new MessageListener(consumer_Listener); 
 _consumer_Listener(_consumer.ReceiveNoWait());
-- 
View this message in context: 
http://www.nabble.com/Queue-gets-clogged-in-OpenWire.NET-when-using-Listener-tf2051829.html#a5685151
Sent from the ActiveMQ - User forum at Nabble.com.

Reply via email to