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

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

Java编程

开发平台：

Java

BibleQueueSender.java：源码内容
  1. package bible.jms;
  5. import javax.jms.*;
  7. import javax.naming.*;
  9. import java.util.*;
  12. /**
  13.  * Class BibleQueueSender
  14.  *
  15.  *
  16.  * @author
  17.  * @version %I%, %G%
  18.  */
  19. public class BibleQueueSender {
  21.   /**
  22.    * Method main
  23.    *
  24.    *
  25.    * @param args
  26.    *
  27.    */
  28.   public static void main(String[] args) {
  30.     Context                ctx                = null;
  31.     Hashtable              ht                 = new Hashtable();
  32.     QueueConnectionFactory qConnectionFactory = null;
  33.     QueueConnection        qConnection        = null;
  34.     QueueSession           qSession           = null;
  35.     QueueSender            qSender            = null;
  36.     Queue                  q                  = null;
  37.     TextMessage            textMsg            = null;
  38.     String                 msg;
  40.     try {
  42.       // Obtain references to JMS queue components.
  43.       ht.put(Context.INITIAL_CONTEXT_FACTORY,
  44.              "weblogic.jndi.WLInitialContextFactory");
  45.       ht.put(Context.PROVIDER_URL, "t3://localhost:7001");
  47.       ctx                = new InitialContext(ht);
  48.       qConnectionFactory =
  49.         (QueueConnectionFactory) ctx.lookup("BibleJMSFactory");
  50.       qConnection        = qConnectionFactory.createQueueConnection();
  51.       qSession           = qConnection.createQueueSession(false,
  52.         javax.jms.QueueSession.AUTO_ACKNOWLEDGE);
  53.       q                  = (Queue) ctx.lookup("BibleJMSQueue");
  54.       qSender            = qSession.createSender(q);
  56.       System.out.println("Sending messages...");
  58.       textMsg = qSession.createTextMessage();
  60.       for (int i = 1; i <= 10; i++) {
  61.         msg = "Message #" + i;
  63.         textMsg.clearBody();
  64.         textMsg.setIntProperty("severity", i);
  65.         textMsg.setText(msg);
  66.         System.out.println("  Sending message: " + msg);
  67.         qSender.send(textMsg);
  68.       }
  70.       msg = "Stop";
  72.       textMsg.clearBody();
  73.       textMsg.setText(msg);
  74.       textMsg.setIntProperty("severity", 0);
  75.       System.out.println("  Sending message: " + msg);
  76.       qSender.send(textMsg);
  77.     } catch (Exception e) {
  78.       e.printStackTrace();
  79.     } finally {
  80.       try {
  82.         // Release JMS resources in reverse order of their creation.
  83.         qSender.close();
  84.         qSession.close();
  85.         qConnection.close();
  86.       } catch (Exception e) {
  87.         e.printStackTrace();
  88.       }
  89.     }
  90.   }
  91. }
  94. /*--- Formatted in Bible Style on Thu, Sep 6, '01 ---*/
  97. /*------ Formatted by Jindent 3.24 Gold 1.02 --- http://www.jindent.de ------*/