activeMQ，spring的jms异步传输

前两天写了一个jms的同步简单例子，地址http://blog.csdn.net/xueyepiaoling/archive/2011/04/13/6321100.aspx

 

只要在“消费者”上动一点小手术，就可以进行异步传输了

 

在"消费者"配置文件上加上

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="rantzDestination" /> <property name="messageListener" ref="marketingGateway" /> </bean> 

"消费者"的java代码也稍作修改

import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; import org.springframework.jms.core.JmsTemplate; public class MarketingReceiverGatewayImpl implements MessageListener { private JmsTemplate jmsTemplate; public JmsTemplate getJmsTemplate() { return jmsTemplate; } public void setJmsTemplate(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } public MarketingReceiverGatewayImpl() { } public void onMessage(Message message) { try { System.out.println("reviced msg is:" + ((TextMessage)message).getText()); } catch (JMSException e) { e.printStackTrace(); } } } 

很简单吧

 

这样，每次有消息的时候，就会进行自动监听了~