browsequeue.java

来自「100多M的J2EE培训内容」· Java 代码 · 共 86 行

package bible.jms;



import javax.jms.*;

import javax.naming.*;

import java.util.*;


/**
 * Class BrowseQueue
 *
 *
 * @author
 * @version %I%, %G%
 */
public class BrowseQueue {

  /**
   * Method main
   *
   *
   * @param args
   *
   */
  public static void main(String[] args) {

    Context                ctx                = null;
    Hashtable              ht                 = new Hashtable();
    QueueConnectionFactory qConnectionFactory = null;
    QueueConnection        qConnection        = null;
    QueueSession           qSession           = null;
    QueueBrowser           qBrowser           = null;
    Queue                  q                  = null;
    TextMessage            textMsg            = null;
    String                 msg;

    try {

      // Obtain references to JMS queue components.
      ht.put(Context.INITIAL_CONTEXT_FACTORY,
             "weblogic.jndi.WLInitialContextFactory");
      ht.put(Context.PROVIDER_URL, "t3://localhost:7001");

      ctx                = new InitialContext(ht);
      qConnectionFactory =
        (QueueConnectionFactory) ctx.lookup("BibleJMSFactory");
      qConnection        = qConnectionFactory.createQueueConnection();
      qSession           = qConnection.createQueueSession(false,
        javax.jms.QueueSession.AUTO_ACKNOWLEDGE);
      q                  = (Queue) ctx.lookup("BibleJMSQueue");
      qBrowser           = qSession.createBrowser(q);

      System.out.println("Browsing messages...");

      Enumeration enum = qBrowser.getEnumeration();

      while (enum.hasMoreElements()) {
        textMsg = (TextMessage) enum.nextElement();

        System.out.println("    " + textMsg.getText());
      }
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {

        // Release JMS resources.
        qBrowser.close();
        qSession.close();
        qConnection.close();
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }
}


/*--- Formatted in Bible Style on Thu, Sep 6, '01 ---*/


/*------ Formatted by Jindent 3.24 Gold 1.02 --- http://www.jindent.de ------*/