智能合约

xiaoyong931011

2023-07-12 91c36cc2d9b5fae741fe5a59e366eb34c7072674

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

@@ -340,4 +340,76 @@
        return BindingBuilder.bind(antKLineQueue()).to(antKLineExchange()).with(QueueEnum.ANT_K_LINE.getRoute());
    }
    // === A k线数据  end ===


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

    @Bean
    public Queue antKLineABQueue() {
        return new Queue(QueueEnum.ANT_K_LINE_AB.getQueue());
    }

    @Bean
    public Binding antKLineABBind() {
        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 ===


    // === 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 ===
}