20221227 充值归集

xiaoyong931011

2023-01-10 73b3813c2d110bf446f251350f120bb1e2b51d0c

 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java

@@ -139,4 +139,52 @@
    }
    // === 奖励分发 end ===

    // === 创建新地址 start ===
    @Bean
    public DirectExchange mallCoinTrcUsdtAddressExchange() {
        return new DirectExchange(RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getExchange());
    }
    @Bean
    public Queue mallCoinTrcUsdtAddressQueue() {
        return new Queue(RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getQueue(), true);
    }
    @Bean
    public Binding mallCoinTrcUsdtAddressBinding() {
        return BindingBuilder.bind(mallCoinTrcUsdtAddressQueue()).to(mallCoinTrcUsdtAddressExchange())
                .with(RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getRoute());
    }
    // === 创建新地址 end ===

    // === usdt更新 start ===
    @Bean
    public DirectExchange mallCoinTrcUsdtUpdateExchange() {
        return new DirectExchange(RabbitQueueEnum.MALL_COIN_TRC_USDT_UPDATE.getExchange());
    }
    @Bean
    public Queue mallCoinTrcUsdtUpdateQueue() {
        return new Queue(RabbitQueueEnum.MALL_COIN_TRC_USDT_UPDATE.getQueue(), true);
    }
    @Bean
    public Binding mallCoinTrcUsdtUpdateBinding() {
        return BindingBuilder.bind(mallCoinTrcUsdtUpdateQueue()).to(mallCoinTrcUsdtUpdateExchange())
                .with(RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getRoute());
    }
    // === usdt更新 end ===

    // === TRC20_USDT同步 start ===
    @Bean
    public DirectExchange mallCoinTrcTrc20Exchange() {
        return new DirectExchange(RabbitQueueEnum.MALL_COIN_TRC_TRC20_BLOCK.getExchange());
    }
    @Bean
    public Queue mallCoinTrcTrc20Queue() {
        return new Queue(RabbitQueueEnum.MALL_COIN_TRC_TRC20_BLOCK.getQueue(), true);
    }
    @Bean
    public Binding mallCoinTrcTrc20Binding() {
        return BindingBuilder.bind(mallCoinTrcTrc20Queue()).to(mallCoinTrcTrc20Exchange())
                .with(RabbitQueueEnum.MALL_COIN_TRC_TRC20_BLOCK.getRoute());
    }
    // === TRC20_USDT同步 end ===

}