xiaoyong931011
2023-07-12 91c36cc2d9b5fae741fe5a59e366eb34c7072674
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -376,4 +376,40 @@
        return BindingBuilder.bind(allMemberPerkAvaQueue()).to(allMemberPerkAvaExchange()).with(QueueEnum.ALL_MEMBER_PERK_AVA.getRoute());
    }
    // === A k线数据  end ===
    // === A 合约铸造ANDAO  start ===
    @Bean
    public DirectExchange contractAnDaoExchange() {
        return new DirectExchange(QueueEnum.CONTRACT_AN_DAO.getExchange());
    }
    @Bean
    public Queue contractAnDaoQueue() {
        return new Queue(QueueEnum.CONTRACT_AN_DAO.getQueue());
    }
    @Bean
    public Binding contractAnDaoBind() {
        return BindingBuilder.bind(contractAnDaoQueue()).to(contractAnDaoExchange()).with(QueueEnum.CONTRACT_AN_DAO.getRoute());
    }
    // === A 合约铸造ANDAO  end ===
    // === A 合约铸造ANDAO  start ===
    @Bean
    public DirectExchange contractAnDaoInExchange() {
        return new DirectExchange(QueueEnum.ANT_A_CION_IN_CONTRACT.getExchange());
    }
    @Bean
    public Queue contractAnDaoInQueue() {
        return new Queue(QueueEnum.ANT_A_CION_IN_CONTRACT.getQueue());
    }
    @Bean
    public Binding contractAnDaoInBind() {
        return BindingBuilder.bind(contractAnDaoInQueue()).to(contractAnDaoInExchange()).with(QueueEnum.ANT_A_CION_IN_CONTRACT.getRoute());
    }
    // === A 合约铸造ANDAO  end ===
}