rabbitmq 整合springboot

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.amqp.core.Queue;

/**
* Created by mc on 17/10/30.
*/
@Configuration
public class RabbitMqConfig {

public static final String rabbitMqQueue = "rabbitMqQueue";

@Bean
public Queue rabbitMqQueue() {
return new Queue(rabbitMqQueue);
}

}

#rabbitmq
spring.rabbitmq.port=5672
spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**
* Created by mc on 17/10/30.
*/
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = CompanyApplication.class)
public class MqTest {

@Autowired
private MqSendAndRecieveService mqSendAndRecieveService;
@Test
public  void send() {
Article article = new Article();
article.setId(1L);
article.setAuthor("wgRoy");
article.setContent("我的文章");
article.setTitle("mq article test");

mqSendAndRecieveService.send(article);
}

}