jmstemplatetest11receive.java

《精通Spring》源代码

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

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.jms.support.JmsUtils;


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

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

        JmsTemplate jt = (JmsTemplate) ac.getBean("jmsTemplate");
        jt.send(new MessageCreator() {
                public Message createMessage(Session session)
                    throws JMSException {
                    return session.createTextMessage(
                        "Hello World(11Receive),queue/testQueue!");
                }
            });

        TextMessage message = (TextMessage) jt.receive();

        try {
            log.info(message.getText());
        } catch (JMSException ex) {
            throw JmsUtils.convertJmsAccessException(ex);
//            log.error("JMSException异常", ex);
        }
    }
}