1、配置文件

      
             
              
           
               
                
            
                 
           
               
            
                 
           
               
                
            
                 
           
               
                    
       
        queue
                 
            
           
           
           
           
               
                
                
            
       
    

2、消息接收监听器

package com.demo.spirng.jms;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageListener;import javax.jms.TextMessage;public class ConsumerMessageListener implements MessageListener {	public void onMessage(Message message) {		// 这里我们知道生产者发送的就是一个纯文本消息，所以这里可以直接进行强制转换		TextMessage textMsg = (TextMessage) message;		try {			System.out.println(textMsg.getText());		} catch (JMSException e) {			e.printStackTrace();		}	}}

3、生产者

package com.demo.spirng.jms;import javax.jms.Destination;public interface ProducerService {	public void sendMessage(Destination destination, final String message);}

package com.demo.spirng.jms;import javax.annotation.Resource;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.Session;import org.springframework.jms.core.JmsTemplate;import org.springframework.jms.core.MessageCreator;import org.springframework.stereotype.Service;@Service("producerService")public class ProducerServiceImpl implements ProducerService {	@Resource	private JmsTemplate jmsTemplate;	public void sendMessage(Destination destination, final String message) {		jmsTemplate.send(destination, new MessageCreator() {			public Message createMessage(Session session) throws JMSException {				return session.createTextMessage(message);			}		});	}}

4、测试

package com.demo.spirng.jms;import javax.jms.Destination;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration("/mqconfig.xml")public class SpringJMSTest {	@Autowired	private ProducerService producerService;	@Autowired	@Qualifier("queueDestination")	private Destination destination;	@Test	public void testProducer() {		String message = "你好，我是一条消息";		producerService.sendMessage(destination, message);	}}

5、注意：

spring-test使用的spring-test-4.0.0.RELEASE.jar