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

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

Java编程

开发平台：

Java

SimpleQueueReceiver.java：源码内容
  1. package demojms;
  3. /*
  4.  * @(#)SimpleQueueReceiver.java
  5.  */
  6. import javax.jms.*;
  7. import javax.naming.*;
  8. import java.util.*;
  10. public class SimpleQueueReceiver {
  11.   public static void main(String[] args) {
  12.     String queueName = null;
  13.     Context jndiContext = null;
  14.     QueueConnectionFactory queueConnectionFactory = null;
  15.     QueueConnection queueConnection = null;
  16.     QueueSession queueSession = null;
  17.     Queue queue = null;
  18.     QueueReceiver queueReceiver = null;
  19.     TextMessage message = null;
  21.     /*
  22.      * 从命令行读queue并显示
  23.      */
  24.     /*if (args.length != 1) {
  25.         System.out.println("Usage: java SimpleQueueReceiver " +
  26.             "<queue-name>");
  27.         System.exit(1);
  28.              }*/
  29.     //queueName = new String(args[0]);
  30.     queueName = "MyTestJMSQueue";
  31.     System.out.println("Queue name is " + queueName);
  33.     /*
  34.      * 如果不存在JNDI InitialContext对象，就创建一个
  35.      */
  36.     try {
  37.       Properties properties = null;
  38.       String url = "t3://127.0.0.1:7001";
  39.       properties = new Properties();
  40.       properties.put(Context.INITIAL_CONTEXT_FACTORY,
  41.                      "weblogic.jndi.WLInitialContextFactory");
  42.       properties.put(Context.PROVIDER_URL, url);
  43.       jndiContext = new InitialContext(properties);
  44.     }
  45.     catch (NamingException e) {
  46.       System.out.println("Could not create JNDI " +
  47.                          "context: " + e.toString());
  48.       System.exit(1);
  49.     }
  51.     /*
  52.      * 寻找connection factory和queue，如果两者读不存在，则退出
  53.      */
  54.     try {
  55.       queueConnectionFactory = (QueueConnectionFactory)
  56.           jndiContext.lookup("MyTestJMS");
  57.       //System.out.println(jndiContext);
  58.       queue = (Queue) jndiContext.lookup("MyTestJMSQueue");
  59.     }
  60.     catch (NamingException e) {
  61.       System.out.println("JNDI lookup failed: "
  62.                          + e.toString());
  63.       System.exit(1);
  64.     }
  66.     /*
  67.      * 创建一个connection，再从connection创建session
  68.      * 创建receiver和文本消息，从queue接收所有的消息
  69.      * 最后，关闭connection
  70.      */
  71.     try {
  72.       queueConnection =
  73.           queueConnectionFactory.createQueueConnection();
  74.       queueSession =
  75.           queueConnection.createQueueSession(false,
  76.                                              Session.AUTO_ACKNOWLEDGE);
  77.       queueReceiver = queueSession.createReceiver(queue);
  78.       queueConnection.start();
  79.       while (true) {
  80.         Message m = queueReceiver.receive(1);
  81.         if (m != null) {
  82.           if (m instanceof TextMessage) {
  83.             message = (TextMessage) m;
  84.             System.out.println("Reading message: " +
  85.                                message.getText());
  86.           }
  87.           else {
  88.             break;
  89.           }
  90.         }
  91.       }
  92.     }
  93.     catch (JMSException e) {
  94.       System.out.println("Exception occurred: " +
  95.                          e.toString());
  96.     }
  97.     finally {
  98.       if (queueConnection != null) {
  99.         try {
  100.           queueConnection.close();
  101.         }
  102.         catch (JMSException e) {}
  103.       }
  104.     }
  105.   }
  106. }