Re: OpenWire - asynchronous consumption
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
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;