Jamsa

<bean id="helloBean" class="mdp.demo.HelloBean" />

	<bean id="jmsTransactionManager"
		class="org.jencks.factory.TransactionManagerFactoryBean" />

	<bean id="activeMQContainer" class="org.jencks.JCAContainer">
		<property name="bootstrapContext" >
			<bean id="bootstrapContext" class="org.jencks.factory.BootstrapContextFactoryBean">
				<property name="transactionManager" ref="jmsTransactionManager"/>
			</bean>
		</property>
		
		<property name="resourceAdapter">
			<bean id="activeMQResourceAdapter"
				class="org.apache.activemq.ra.ActiveMQResourceAdapter">
				<property name="serverUrl"
					value="tcp://localhost:61616" />
			</bean>
		</property>
	</bean>


	<bean id="HelloMDP" class="org.jencks.JCAConnector">
		<property name="jcaContainer" ref="activeMQContainer" />
		<property name="transactionManager" ref="jmsTransactionManager" />
		<property name="activationSpec">
			<bean
				class="org.apache.activemq.ra.ActiveMQActivationSpec">
				<property name="destination" value="Hello.Queue" />
				<property name="destinationType"
					value="javax.jms.Queue" />
			</bean>
		</property>
		<property name="ref" value="helloBean" />
	</bean>

package mdp.demo;

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

public class HelloBean implements MessageListener {

	public void onMessage(Message msg) {
		try {
			String name = msg.getStringProperty("name");
			if (name == null) {
				name = "World";
			}

			System.out.println("Hello " + name + "!");
		} catch (JMSException e) {
			e.printStackTrace();
		}

	}

}

<bean id="jmsTemplate"
		class="org.springframework.jms.core.JmsTemplate">
		<property name="defaultDestinationName" value="Hello.Queue" />
		<property name="connectionFactory" ref="connectionFactory" />
	</bean>
<bean id="connectionFactory"
		class="org.apache.activemq.ActiveMQConnectionFactory">
		<property name="brokerURL" value="tcp://localhost:61616" />
	</bean>

package mdp.demo;

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

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class MDPClient {
	public static void main(String[] args) {
		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"spring-client.xml");

		JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
		template.setDefaultDestinationName("Hello.Queue");
		template.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				MapMessage message = session.createMapMessage();
				message.setStringProperty("name", "消息驱动POJO");
				return message;
			}
		});
		
		
	}
}