ITPub博客

首页 > Linux操作系统 > Linux操作系统 > [原创]深入掌握JMS(三):MessageListener

[原创]深入掌握JMS(三):MessageListener

原创 Linux操作系统 作者:21ca 时间:2009-03-26 13:48:22 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();
                }
            }
           
        });

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/10742815/viewspace-580252/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2009-03-24

  • 博文量
    58
  • 访问量
    87026