SessionPoolConsumer.java
上传用户:dinglihq
上传日期:2013-02-04
资源大小:99958k
文件大小:2k
源码类别:

Java编程

开发平台:

Java

  1. package bible.jms;
  2. import javax.jms.*;
  3. /**
  4.  * Class SessionPoolConsumer
  5.  *
  6.  *
  7.  * @author
  8.  * @version %I%, %G%
  9.  */
  10. public class SessionPoolConsumer implements MessageListener {
  11.   /**
  12.    * Method onMessage
  13.    *
  14.    *
  15.    * @param message
  16.    *
  17.    */
  18.   public void onMessage(Message message) {
  19.     if (message instanceof BytesMessage) {
  20.       BytesMessage bytesMessage = (BytesMessage) message;
  21.       // Process bytesMessage here
  22.     } else {
  23.       if (message instanceof MapMessage) {
  24.         MapMessage mapMessage = (MapMessage) message;
  25.         // Process mapMessage here
  26.       } else {
  27.         if (message instanceof ObjectMessage) {
  28.           ObjectMessage objectMessage = (ObjectMessage) message;
  29.           // Process objectMessage here
  30.         } else {
  31.           if (message instanceof StreamMessage) {
  32.             StreamMessage streamMessage = (StreamMessage) message;
  33.             // Process streamMessage here
  34.           } else {
  35.             if (message instanceof TextMessage) {
  36.               try {
  37.                 TextMessage textMessage = (TextMessage) message;
  38.                 // Process textMessage here
  39.                 String msg = textMessage.getText();
  40.                 System.out.println("Received message: " + msg);
  41.               } catch (Exception e) {
  42.                 e.printStackTrace();
  43.               }
  44.             }
  45.           }
  46.         }
  47.       }
  48.     }
  49.   }
  50. }
  51. /*--- Formatted in Bible Style on Thu, Sep 6, '01 ---*/
  52. /*------ Formatted by Jindent 3.24 Gold 1.02 --- http://www.jindent.de ------*/