ActiveMQ之MessageListener

标签：

消息的消费者接收消息可以采用两种方式：
1.consumer.receive()或 consumer.receive(int timeout);
2.注册一个MessageListener.
采用第一种方式，消息的接收者会一直等待下去，知道有消息到达或者超时。后一种方式会注册一个监听器，
当有消息到达的时候，会调用它的onMessage()方法。以下举例说明:
MessageConsumer consumer=session.createConsumer(queue);
consumer.setMessageListener(new MessageListener(){
public void onMessage(Message msg)
{
System.out.println("接收到的消息为+"((TextMessage)msg).getText());
}
})

ActiveMQ之MessageListener

标签：

原文地址：http://www.cnblogs.com/fjhh/p/5370581.html