ActiveMQ与Spring的例子

public class ActivemqTest extends TestCase {

	@Test
	public void testJmsTemplateSend() {

		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"/applicationContext-jms.xml");
		JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
		Destination destination = (Destination) ctx.getBean("destination");

		template.send(destination, new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				return session
						.createTextMessage("发送消息：Hello ActiveMQ Text Message！");
			}
		});
		System.out.println("成功发送了一条JMS消息");
	}

	@Test
	public void testJmsTemplateReceive() throws JMSException {
		ApplicationContext ctx = new ClassPathXmlApplicationContext(
				"/applicationContext-jms.xml");
		JmsTemplate template = (JmsTemplate) ctx.getBean("jmsTemplate");
		Destination destination = (Destination) ctx.getBean("destination");
		while (true) {
			TextMessage txtmsg = (TextMessage) template.receive(destination);
			if (null != txtmsg)
				System.out.println("收到消息内容为: " + txtmsg.getText());
			else
				break;
		}
	}

}

applicationContext-jms.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-2.5.xsd">

    <!-- 配置JMS连接工厂 -->
    <bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>

    <!-- 配置JMS模版 -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>

    <!-- 发送消息的目的地（一个队列） -->
    <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
        <!-- Set the Queue Name -->
        <constructor-arg index="0" value="HelloWorldQueue"/>
    </bean>
</beans>

特殊的jar

activemq-core-5.2.0.jar
geronimo-j2ee-management_1.0_spec-1.0.jar
spring-jms-2.5.5.jar
xbean-spring-3.4.jar

评论

1 楼 liangjian103 2013-04-17  

引用哪些包呢？ import的时候，有很多包让选择，不知道该选哪个。