example16messagedrivenbeanclient.java

《精通Spring》源代码

/*
 * Created on 2004-12-25
 *
 * 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 org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

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


/**
 * Example16MessageDrivenBeanClient，用于发送消息。
 *
 * @author luoshifei
 */
public class Example16MessageDrivenBeanClient {
    protected static final Log log = LogFactory.getLog(Example16MessageDrivenBeanClient.class);

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

        JmsTemplate jt = (JmsTemplate) ac.getBean("jmsTemplate");

        for (int i = 0; i < 5; ++i) {
            jt.send(new MessageCreator() {
                    public Message createMessage(Session session)
                        throws JMSException {
                        return session.createTextMessage(
                            "Hello World(MDB),queue/testQueue!," +
                            System.currentTimeMillis());
                    }
                });
        }

        log.info("成功发送消息！");
    }
}