jmstemplatetest11converter.java

《精通Spring》源代码

/*
 * Created on 2004-11-9
 *
 * 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.MessagePostProcessor;

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


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

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

        JmsTemplate jt = (JmsTemplate) ac.getBean("jmsTemplate");
        String str = "Hello World";
        jt.convertAndSend(jt.getDefaultDestination(), str,
            new MessagePostProcessor() {
                public Message postProcessMessage(Message message)
                    throws JMSException {
                    message.setIntProperty("helloworldid", 12345678);
                    message.setJMSCorrelationID("1234-5678");
                    message.setJMSExpiration(40000000);

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