fix

Hentua

2023-06-15 8bf923b44bbe9b45b73ddcc25df75c9c59f54e07

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

@@ -143,4 +143,66 @@
    }
    //补贴金额 end

    /**
     * 强制卖出
     * @return
     */
    //强制卖出 start
    @Bean
    public DirectExchange forceVoucherSaleExchange() {
        return new DirectExchange(RabbitQueueEnum.FORCE_VOUCHER_SALE.getExchange());
    }

    @Bean
    public Queue forceVoucherSaleQueue() {
        return new Queue(QueueConstants.FORCE_VOUCHER_SALE);
    }

    @Bean
    public Binding forceVoucherSaleBind() {
        return BindingBuilder.bind(forceVoucherSaleQueue()).to(forceVoucherSaleExchange()).with(RabbitQueueEnum.FORCE_VOUCHER_SALE.getRoute());
    }
    //强制卖出 end


    /**
     * 订单分红
     * @return
     */
    //订单分红 start
    @Bean
    public DirectExchange orderBonusExchange() {
        return new DirectExchange(RabbitQueueEnum.ORDER_BONUS.getExchange());
    }

    @Bean
    public Queue orderBonusQueue() {
        return new Queue(QueueConstants.ORDER_BONUS);
    }

    @Bean
    public Binding orderBonusBind() {
        return BindingBuilder.bind(orderBonusQueue()).to(orderBonusExchange()).with(RabbitQueueEnum.ORDER_BONUS.getRoute());
    }
    //订单分红 end


    /**
     * 矩阵节点
     * @return
     */
    @Bean
    public DirectExchange matrixTreeExchange() {
        return new DirectExchange(RabbitQueueEnum.MATRIX_TREE.getExchange());
    }

    @Bean
    public Queue matrixTreeQueue() {
        return new Queue(QueueConstants.MATRIX_TREE);
    }

    @Bean
    public Binding matrixTreeBind() {
        return BindingBuilder.bind(matrixTreeQueue()).to(matrixTreeExchange()).with(RabbitQueueEnum.MATRIX_TREE.getRoute());
    }
}