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

miss_all 发布于 2017/01/17 11:59
阅读 1K+
收藏 0


// 启动类

@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");
    }
}


/**
 * 消费者
 * 
 * @date 2017年1月16日 下午8:20:25
 */
@Component
public class Consumer {

@JmsListener(destination = "sample.queue")
    public void receiveQueue(String text) {
       System.out.println(text);  // 这里收不到text  不知道是否还需要配置其他内容,
    }
}

以上例子基本上跟springboot官方给的样例一模一样的。但是就是没有收到  【hi,activeMQ】 这个结果进行打印,求大神帮忙

加载中
0
skhuhu
skhuhu
这个样例是可以用的····前提是在application.yml里别配置mq 的属性
0
MR_AMYLEE
MR_AMYLEE
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配置

返回顶部
顶部