main.java

ActiveMQ + Spring的例子

package com.liangj.apmgt;

import org.apache.log4j.PropertyConfigurator;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.liangj.apmgt.jms.IApmgtMessageProducer;
import com.liangj.apmgt.message.ApmgtModPasswordRequest;
import com.liangj.apmgt.message.MessageHeader;
import com.liangj.apmgt.message.ModPasswordRequest;


public class Main {

	public static void main(final String[] args) throws Exception {
		
		PropertyConfigurator.configure("log4j.properties");
		
		AbstractApplicationContext ctx = new ClassPathXmlApplicationContext(new String[] { "spring-jms.xml" });
//		ctx.registerShutdownHook();
		
		IApmgtMessageProducer producer = (IApmgtMessageProducer)ctx.getBean("producer");
		
		ApmgtModPasswordRequest messageData = new ApmgtModPasswordRequest();
		messageData.setMessageHeader(new MessageHeader());
		messageData.setMessageContent(new ModPasswordRequest());
		messageData.init();
		
		producer.sendMessage(messageData);
	}
}