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

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

Java编程

开发平台：

Java

QueueFiller.java：源码内容
  1. package bible.webservices.message.producer;
  5. import javax.naming.*;
  7. import javax.jms.*;
  9. import java.util.*;
  12. /**
  13.  * Class QueueFiller
  14.  *
  15.  *
  16.  * @author
  17.  * @version %I%, %G%
  18.  */
  19. public class QueueFiller {
  21.   /**
  22.    * Constructor QueueFiller
  23.    *
  24.    *
  25.    */
  26.   public QueueFiller() {}
  28.   /**
  29.    * Method main
  30.    *
  31.    *
  32.    * @param args
  33.    *
  34.    */
  35.   public static void main(String[] args) {
  37.     Context                ctx                = null;
  38.     QueueConnectionFactory qConnectionFactory = null;
  39.     QueueConnection        qConnection        = null;
  40.     QueueSession           qSession           = null;
  41.     QueueSender            qSender            = null;
  43.     try {
  44.       Properties props = new Properties();
  46.       props.put(Context.INITIAL_CONTEXT_FACTORY,
  47.                 "weblogic.jndi.WLInitialContextFactory");
  48.       props.put(Context.PROVIDER_URL, "t3://localhost:7001");
  50.       ctx                = new InitialContext(props);
  51.       qConnectionFactory =
  52.         (QueueConnectionFactory) ctx
  53.           .lookup("bible/ws/message/ReceiveConnectionFactory");
  54.       qConnection        = qConnectionFactory.createQueueConnection();
  55.       qSession           = qConnection.createQueueSession(false,
  56.         javax.jms.QueueSession.AUTO_ACKNOWLEDGE);
  58.       Queue q = (Queue) ctx.lookup("ReceiveQueue");
  60.       qSender = qSession.createSender(q);
  62.       System.out.println("Sending messages to the client...");
  64.       ObjectMessage message = qSession.createObjectMessage();
  66.       for (int i = 0; i < 10; i++) {
  67.         message.clearBody();
  68.         message.setObject("Message #" + i + " data to the client");
  69.         System.out.println("Sending message #" + i);
  70.         qSender.send(message);
  71.       }
  73.       message.clearBody();
  74.       message.setObject("Stop");
  75.       System.out.println("Sending message " + message.getObject());
  76.       qSender.send(message);
  77.     } catch (Exception e) {
  78.       e.printStackTrace();
  79.     } finally {
  80.       try {
  81.         qSender.close();
  82.         qSession.close();
  83.         qConnection.close();
  84.       } catch (Exception ex) {}
  85.     }
  86.   }
  87. }
  90. /*--- Formatted in Bible Style on Thu, Sep 6, '01 ---*/
  93. /*------ Formatted by Jindent 3.24 Gold 1.02 --- http://www.jindent.de ------*/