spring boot示例项目添加activemq消费者收不到消息

Question

// 启动类

@SpringBootApplication

@EnableJms

public class Application {

    @Bean
    public Queue queue() {
       return new ActiveMQQueue("sample.queue");
    }
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

/**
 * 生产者
 * 
 * @date 2017年1月16日 下午8:19:52
 */
@Component
@EnableScheduling
public class Producer {

@Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;


    @Autowired
    private Queue queue;
    
    @Scheduled(fixedDelay=3000)//每3s执行1次
    public void send() {
       this.jmsMessagingTemplate.convertAndSend(this.queue, "hi,activeMQ");
    }
}

Answer 1

spring.activemq.broker-url=tcp://192.168.4.100:61616
spring.activemq.user=admin
spring.activemq.password=admin
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false

 

application.properties 里面需要加mq配置

Answer 2

这个样例是可以用的····前提是在application.yml里别配置mq 的属性