rabbitMQ JAVA开发 demo文件

package test; import org.junit.Before; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; /** * Created by Nebintel Group. * Project:itspapi * Package:com.nebintel.api.rabbitmq * Author: WuYangYang * Date: 2017/7/17 0017 */ public class MessageTest { private Logger logger = LoggerFactory.getLogger(MessageTest.class); private ApplicationContext context = null; @Before public void setUp() throws Exception { context = new ClassPathXmlApplicationContext("spring/applicationContext2.xml"); } @Test public void should_send_a_amq_message() throws Exception { MessageProducer messageProducer = (MessageProducer) context.getBean("messageProducer"); int a = 10; while (a > 0) { messageProducer.sendMessage("Hello, I am amq sender num :" + a--); try { //暂停一下，好让消息消费者去取消息打印出来 Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }