queuemanager.java

BEA WebLogic Server 8.1大全 = BEA webLogic server 8.1 unleashed (美) Mark Artiges等著 袁毅 ... [等] 译 eng

package com.wls8unleashed.jms;

import javax.jms.*;
import javax.naming.*;

/**
 * Provides common initialization work used for Queue
 * consumers and suppliers.
 */
public class QueueManager {

  protected QueueConnectionFactory queueConnectionFactory;
  protected QueueConnection queueConnection;
  protected QueueSession queueSession;
  protected Queue queue;

	/**
	 * Creates and initializes a bunch of queue resources.
	 */
  public QueueManager(Context context){
    
    try{    
      // Get JMS factory JNDI name
      String jmsFactoryName = Props.get("jms.factory.for.queue");
  
      // Create queue connection factory
      System.out.println("Looking up factory name: " + jmsFactoryName);
      queueConnectionFactory =
        (QueueConnectionFactory) context.lookup(jmsFactoryName);
  
      // Create queue connection to the factory
      System.out.println("Creating queue connection...");
      queueConnection = queueConnectionFactory.createQueueConnection();
  
      // Create session to the connection
      System.out.println("Creating queue session...");
      queueSession = queueConnection.createQueueSession(
                                      false, Session.AUTO_ACKNOWLEDGE);
  
      // Get queue name
      String queueName = Props.get("queue.name");
  
      // Lookup handle to the Queue
      try {
      	System.out.println("Looking up queue name: " + queueName);
        queue = (Queue) context.lookup(queueName);
      } catch (NamingException namingException) {
        // If not created, create new queue, and bind queue to name
        System.out.println("Didn't find the queue...so creating: " + queueName);
        queue = queueSession.createQueue(queueName);
        System.out.println("Binding queue: " + queueName);
        context.bind(queueName, queue);
      }
    }
    catch(Exception e){
      System.out.println("PROBLEM CREATING QUEUE MANAGER");
      e.printStackTrace();
    }
  }
}