- import javax.jms.JMSException;
- import javax.jms.Message;
- import javax.jms.MessageListener;
- import javax.jms.TextMessage;
- public class ConsumerMessageListener implements MessageListener {
- public void onMessage(Message message) {
- //這裏咱們知道生產者發送的就是一個純文本消息,因此這裏能夠直接進行強制轉換,或者直接把onMessage方法的參數改爲Message的子類TextMessage
- TextMessage textMsg = (TextMessage) message;
- System.out.println("接收到一個純文本消息。");
- try {
- System.out.println("消息內容是:" + textMsg.getText());
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- }