queuetest.java

《精通Spring》源代码

/*
 * Created on 2004-11-6
 *
 * http://www.open-v.com 提供代码的维护工作
 */
package com.openv.spring;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import javax.jms.JMSException;
import javax.jms.Queue;


/**
 * QueueTest客户应用
 *
 * @author luoshifei
 */
public class QueueTest {
    protected static final Log log = LogFactory.getLog(QueueTest.class);

    public static void main(String[] args) {
        ApplicationContext ac = new ClassPathXmlApplicationContext(
                "appcontext.xml");
        Queue queue = (Queue) ac.getBean("queue");

        try {
            log.info("消息队列名称：" + queue.getQueueName());
        } catch (JMSException ex) {
            log.error("消息异常", ex);
        }
    }
}

//        try {
//            InitialContext initialContext = new InitialContext();
//            Queue queue = (Queue) initialContext.lookup("queue/testQueue");
//            log.info("消息队列名称：" + queue.getQueueName());
//        } catch (JMSException ex) {
//            log.error("消息异常", ex);
//        } catch (NamingException ex) {
//            log.error("命名异常", ex);
//        }