cpvbug修复

zainali5120

2020-10-07 c91253f0c71f420fe681be65575e0b6ff87dc31c

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

@@ -89,6 +89,13 @@
    // 交易订单处理
    public static final String ROUTINGKEY_HANDLE_TRADE = "ROUTINGKEY_HANDLE_TRADE";

    public static final String EXCHANGE_ROC = "roc-transfer";

    public static final String QUEUE_ROC= "roc-queue";

    public static final String ROUTING_KEY_ROC = "roc-transfer-routingKey";


    @Resource
    private ConnectionFactory connectionFactory;

@@ -351,4 +358,20 @@
        return BindingBuilder.bind(queueHandleTrade()).to(matchTradeExchange()).with(RabbitMqConfig.ROUTINGKEY_HANDLE_TRADE);
    }

    @Bean
    public DirectExchange rocExchange() {
        return new DirectExchange(EXCHANGE_ROC);
    }


    @Bean
    public Queue rocQueue() {
        return new Queue(QUEUE_ROC, true);
    }

    @Bean
    public Binding bindingRoc() {
        return BindingBuilder.bind(rocQueue()).to(rocExchange()).with(ROUTING_KEY_ROC);
    }

}