厚積而薄發(fā)

          山不辭土,故能成其高;海不辭水,故能成其深!
          posts - 15, comments - 0, trackbacks - 0, articles - 1

          深入掌握JMS(三):MessageListener

          Posted on 2009-10-30 14:19 Robin 閱讀(261) 評論(0)  編輯  收藏
          消息的消費者接收消息可以采用兩種方式:

          1、consumer.receive() 或 consumer.receive(int timeout);
          2、注冊一個MessageListener。

          采用第一種方式,消息的接收者會一直等待下去,直到有消息到達,或者超時。后一種方式會注冊一個監(jiān)聽器,當有消息到達的時候,會回調(diào)它的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();
                          }
                      }
                     
                  });


          只有注冊用戶登錄后才能發(fā)表評論。


          網(wǎng)站導航:
           
          主站蜘蛛池模板: 称多县| 五大连池市| 临夏市| 内乡县| 莱阳市| 锡林郭勒盟| 商南县| 休宁县| 宜君县| 曲沃县| 钦州市| 合作市| 徐水县| 本溪市| 南京市| 临沭县| 衡山县| 汉源县| 剑川县| 五大连池市| 阳谷县| 招远市| 伊金霍洛旗| 双辽市| 日喀则市| 京山县| 龙泉市| 巴林右旗| 中卫市| 丹江口市| 黄大仙区| 扶绥县| 神农架林区| 保定市| 定日县| 通城县| 呈贡县| 商洛市| 铜山县| 武夷山市| 平度市|