生产者
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);
}
}