Re: OpenWire - asynchronous consumption

2006-05-23 Thread vince-el-matador
U can do like this : consumer.Listener += new MessageListener(OnMessage); with protected void OnMessage(IMessage message) { ActiveMQTextMessage msg = message as ActiveMQTextMessage; // do whatever U like with msg } -- View this message in context:

Openwire client hangs after receiving 999 messages

2006-05-23 Thread vince-el-matador
using .NET 2.0 ,C# + trunk, the consumer async call back hangs at 999th call ! Here is the code : public void allInOne() { ISession session; IDestination destination; IConnectionFactory factory; IMessageProducer producer; IMessageConsumer consumer;