20210115

xiaoyong931011

2021-01-15 292a4634d9c52ce193eca9de356d65960bdc35f4

 src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java

@@ -121,6 +121,12 @@

    public static final String ROUTING_KEY_ROC_ORDER_CANCEL  = "roc-order-routingKey-cancel";

    public static final String EXCHANGE_ROC_ORDER_COMPLETE = "roc-exchange-order-complete";

    public static final String QUEUE_ROC_ORDER_COMPLETE = "roc-order-queue-complete";

    public static final String ROUTING_KEY_ROC_ORDER_COMPLETE  = "roc-order-routingKey-complete";


    @Resource
    private ConnectionFactory connectionFactory;
@@ -189,6 +195,22 @@
    public Binding bindingCancelOrder() {
        return BindingBuilder.bind(ordereCancelQueue()).to(orderCancelExchange()).with(ROUTING_KEY_ROC_ORDER_CANCEL);
    }
   // 交易订单
    @Bean
    public DirectExchange orderCompleteExchange() {
        return new DirectExchange(EXCHANGE_ROC_ORDER_COMPLETE);
    }


    @Bean
    public Queue ordereCompleteQueue() {
        return new Queue(QUEUE_ROC_ORDER_COMPLETE, true);
    }

    @Bean
    public Binding bindingCompleteOrder() {
        return BindingBuilder.bind(ordereCompleteQueue()).to(orderCompleteExchange()).with(ROUTING_KEY_ROC_ORDER_COMPLETE);
    }


   @Bean