Posted on 2009-10-30 14:19
Robin 閱讀(255)
評論(0) 編輯 收藏
消息的消費者接收消息可以采用兩種方式:
1、consumer.receive() 或 consumer.receive(int timeout);
2、注冊一個MessageListener。
采用第一種方式,消息的接收者會一直等待下去,直到有消息到達,或者超時。后一種方式會注冊一個監聽器,當有消息到達的時候,會回調它的onMessage()方法。下面舉例說明:
MessageConsumer comsumer = session.createConsumer(queue);
comsumer.setMessageListener(new MessageListener(){
@Override
public void onMessage(Message m) {
TextMessage textMsg = (TextMessage) m;
try {
System.out.println(textMsg.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});