学步园

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

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

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

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

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

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

很简单吧

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