20221220

xiaoyong931011

2022-12-21 b5ea51a413dc474d471c7c1572730f5cf73d6c25

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

@@ -91,4 +91,52 @@
        return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
    }

    @Bean
    public DirectExchange agentReturnMoneyExchange() {
        return new DirectExchange(RabbitQueueEnum.AGENT_REUTRN_MONEY.getExchange());
    }

    @Bean
    public Queue agentReturnMoneyQueue() {
        return new Queue(QueueConstants.AGENT_RETURN_MONEY);
    }

    @Bean
    public Binding agentReturnMoneyBind() {
        return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.AGENT_REUTRN_MONEY.getRoute());
    }


    @Bean
    public DirectExchange orderReturnMoneyExchange() {
        return new DirectExchange(RabbitQueueEnum.ORDER_RETURN_MONEY.getExchange());
    }

    @Bean
    public Queue orderReturnMoneyQueue() {
        return new Queue(QueueConstants.ORDER_RETURN_MONEY);
    }

    @Bean
    public Binding orderReturnMoneyBind() {
        return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute());
    }

    // === 奖励分发 start ===
    @Bean
    public DirectExchange mallCoinDirectRewardExchange() {
        return new DirectExchange(RabbitQueueEnum.MALL_COIN_DIRECT_REWARD.getExchange());
    }

    @Bean
    public Queue mallCoinDirectRewardQueue() {
        return new Queue(RabbitQueueEnum.MALL_COIN_DIRECT_REWARD.getQueue());
    }

    @Bean
    public Binding mallCoinDirectRewardBind() {
        return BindingBuilder.bind(mallCoinDirectRewardQueue()).to(mallCoinDirectRewardExchange()).with(RabbitQueueEnum.MALL_COIN_DIRECT_REWARD.getRoute());
    }
    // === 奖励分发 end ===

}