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());
}
})


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM