Springboot整合activeMq

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

spring:
  activemq:
    broker-url: tcp://ip:61616
    user: admin
    password: admin
queue: queue_name

/**
 * 创建一个队列
 */
@Configuration
public class QueueConfig {

    @Value("${queue}")
    private String queueName;

    @Bean
    public Queue queue(){
        return new ActiveMQQueue(queueName);
    }
}

/**
 * 生产者
 */
@Component
@EnableScheduling
public class Producer {


    @Autowired
    JmsMessagingTemplate jmsMessagingTemplate;


    @Autowired
    private Queue queue;

    private int i = 0;

    //定时器每隔5秒向activmq服务器发送一条消息
    @Scheduled(fixedDelay = 5000)
    public void send(){
        i ++;
        jmsMessagingTemplate.convertAndSend(queue, "第"+i+"条数据");
    }

}

/**
 * 消费者
 */
@Component
public class Consumer {

    @JmsListener(destination = "${queue}")
    public void receive(String msg){
        System.out.println("消费者"+msg);
    }
    
}