开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Java编程 > 查看源码
QueueReader.java
资源名称：某公司的java培训教材　[点击查看]
上传用户：dinglihq
上传日期：2013-02-04
资源大小：99958k
文件大小：1k
源码类别：

Java编程

开发平台：

Java

QueueReader.java：源码内容
  1. package bible.webservices.message.consumer;
  5. import javax.jms.*;
  7. import javax.naming.*;
  9. import javax.ejb.CreateException;
  10. import javax.ejb.MessageDrivenContext;
  11. import javax.ejb.MessageDrivenBean;
  13. import java.rmi.RemoteException;
  16. /**
  17.  * Class QueueReader
  18.  *
  19.  *
  20.  * @author
  21.  * @version %I%, %G%
  22.  */
  23. public class QueueReader implements MessageDrivenBean, MessageListener {
  25.   private transient MessageDrivenContext mdc = null;
  26.   private Context                        context;
  28.   /**
  29.    * Constructor QueueReader
  30.    *
  31.    *
  32.    */
  33.   public QueueReader() {}
  35.   /**
  36.    * Method setMessageDrivenContext
  37.    *
  38.    *
  39.    * @param mdc
  40.    *
  41.    */
  42.   public void setMessageDrivenContext(MessageDrivenContext mdc) {
  43.     this.mdc = mdc;
  44.   }
  46.   /**
  47.    * Method ejbCreate
  48.    *
  49.    *
  50.    */
  51.   public void ejbCreate() {}
  53.   /**
  54.    * Method ejbRemove
  55.    *
  56.    *
  57.    */
  58.   public void ejbRemove() {}
  60.   /**
  61.    * Method onMessage
  62.    *
  63.    *
  64.    * @param message
  65.    *
  66.    */
  67.   public void onMessage(Message message) {
  69.     ObjectMessage tm = (ObjectMessage) message;
  71.     try {
  72.       System.out.println("The text in the message was " + tm.getObject());
  73.     } catch (Exception e) {
  74.       e.printStackTrace();
  75.     }
  76.   }
  77. }
  80. /*--- Formatted in Bible Style on Thu, Sep 6, '01 ---*/
  83. /*------ Formatted by Jindent 3.24 Gold 1.02 --- http://www.jindent.de ------*/