MQ集成

<dependency>
	<artifactId>csx-bsf-mq</artifactId>
	<groupId>com.yh.csx.bsf</groupId>
	<version>1.7.1-SNAPSHOT</version>
</dependency>

#mq
bsf.mq.enabled = false
bsf.rocketmq.namesrvaddr = 127.252.193.20:9876;127.252.193.18:9876

    @Autowired(required = false)
    private RocketMQProducerProvider rocketMQProducerProvider;
    @Autowired(required = false)
    private RocketMQConsumerProvider rocketMQConsumerProvider;

    public static void main(String[] args){
        ApplicationContext context = SpringApplication.run(ProducerApplication.class, args);
        
        //订阅消息
        RocketMQConsumerProvider consumerProvider = context.getBean(RocketMQConsumerProvider.class);
        consumerProvider.subscribe("csx-bsf-demo-test-consumer-01","csx-bsf-demo-test",(msg)->{
            System.out.println(msg);
        },String.class);
        
        //发送消息
        rocketMQProducerProvider.sendMessage("csx-bsf-demo-test","测试"+ DateUtils.formatTime(new Date()));
    }