twoCoin项目修改

xiaoyong931011

2023-06-08 52a7fcbe3f824dfc4cf8b0eedcb3a498f2618a56

 src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java

@@ -358,4 +358,22 @@
        return BindingBuilder.bind(antKLineABQueue()).to(antKLineABExchange()).with(QueueEnum.ANT_K_LINE_AB.getRoute());
    }
    // === A k线数据  end ===


    // === A k线数据  start ===
    @Bean
    public DirectExchange allMemberPerkAvaExchange() {
        return new DirectExchange(QueueEnum.ALL_MEMBER_PERK_AVA.getExchange());
    }

    @Bean
    public Queue allMemberPerkAvaQueue() {
        return new Queue(QueueEnum.ALL_MEMBER_PERK_AVA.getQueue());
    }

    @Bean
    public Binding allMemberPerkAvaBind() {
        return BindingBuilder.bind(allMemberPerkAvaQueue()).to(allMemberPerkAvaExchange()).with(QueueEnum.ALL_MEMBER_PERK_AVA.getRoute());
    }
    // === A k线数据  end ===
}