生产者

1.导入相关依赖

2.交给Spring管理，写入相关配置JmsTemplate

 

@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(location={"classpath:config/applicationContext.xml"})pulibc class ProducterTest{    @Autowired    private JmsTemplate jmsTemplate;    @Test    public  void productMsg(){        jmsTemplate.convertAndSent("hello,我是activeMq");        }}

 

消费者

在spirng管理配置中还需要配置一个监听器，来监听是否有消息。

 

public class ConsumerMessageListener implements  MessageListener{    //这个方法，它就会在activeMq中有消息时候执行    public void  onMessage(Message message){        System.out.println("消费者获取到的消息是："+message);    }}