消息的消費者接收消息可以采用兩種方式:
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());
}
})