Administrator
1 days ago d3492864ec22a30e9fcc99b2b174cf6eb9531399
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -238,4 +238,68 @@
        return BindingBuilder.bind(activityOrderCheckQueue()).to(activityOrderCheckExchange()).with(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getRoute());
    }
    @Bean
    public DirectExchange clothesAddLikeExchange() {
        return new DirectExchange(RabbitQueueEnum.CLOTHES_ADD_LIKE.getExchange());
    }
    @Bean
    public Queue clothesAddLikeQueue() {
        return new Queue(RabbitQueueEnum.CLOTHES_ADD_LIKE.getQueue());
    }
    @Bean
    public Binding clothesAddLikeBind() {
        return BindingBuilder.bind(clothesAddLikeQueue()).to(clothesAddLikeExchange()).with(RabbitQueueEnum.CLOTHES_ADD_LIKE.getRoute());
    }
    @Bean
    public DirectExchange clothesAddCollectExchange() {
        return new DirectExchange(RabbitQueueEnum.CLOTHES_ADD_COLLECT.getExchange());
    }
    @Bean
    public Queue clothesAddCollectQueue() {
        return new Queue(RabbitQueueEnum.CLOTHES_ADD_COLLECT.getQueue());
    }
    @Bean
    public Binding clothesAddCollectBind() {
        return BindingBuilder.bind(clothesAddCollectQueue()).to(clothesAddCollectExchange()).with(RabbitQueueEnum.CLOTHES_ADD_COLLECT.getRoute());
    }
    @Bean
    public DirectExchange knowledgeAddExchange() {
        return new DirectExchange(RabbitQueueEnum.KNOWLEDGE_ADD_ALI.getExchange());
    }
    @Bean
    public Queue knowledgeAddQueue() {
        return new Queue(RabbitQueueEnum.KNOWLEDGE_ADD_ALI.getQueue());
    }
    @Bean
    public Binding knowledgeAddBind() {
        return BindingBuilder.bind(knowledgeAddQueue()).to(knowledgeAddExchange()).with(RabbitQueueEnum.KNOWLEDGE_ADD_ALI.getRoute());
    }
    @Bean
    public DirectExchange questionAddExchange() {
        return new DirectExchange(RabbitQueueEnum.QUESTION_ADD_ALI.getExchange());
    }
    @Bean
    public Queue questionAddQueue() {
        return new Queue(RabbitQueueEnum.QUESTION_ADD_ALI.getQueue());
    }
    @Bean
    public Binding questionAddBind() {
        return BindingBuilder.bind(questionAddQueue()).to(questionAddExchange()).with(RabbitQueueEnum.QUESTION_ADD_ALI.getRoute());
    }
}