golden交易所分布式支持

zainali5120

2020-10-10 f8a0008705fd8067959151ce83c5dce19e72fb85

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

@@ -103,6 +103,12 @@

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

    public static final String EXCHANGE_ROC_ORDER_SUBMIT = "roc-exchange-order-submit";

    public static final String QUEUE_ROC_ORDER_SUBMIT = "roc-order-queue-submit";

    public static final String ROUTING_KEY_ROC_ORDER_SUBMIT  = "roc-order-routingKey-submit";


    @Resource
    private ConnectionFactory connectionFactory;
@@ -138,6 +144,23 @@
        return BindingBuilder.bind(testQueue()).to(defaultExchange()).with(ROUTING_KEY_TEST);
    }

    // 交易订单
    @Bean
    public DirectExchange orderSubmitExchange() {
        return new DirectExchange(EXCHANGE_ROC_ORDER_SUBMIT);
    }


    @Bean
    public Queue ordereSubmitQueue() {
        return new Queue(QUEUE_ROC_ORDER_SUBMIT, true);
    }

    @Bean
    public Binding bindingSubmitOrder() {
        return BindingBuilder.bind(ordereSubmitQueue()).to(orderSubmitExchange()).with(ROUTING_KEY_ROC_ORDER_SUBMIT);
    }


   @Bean
    public DirectExchange usdtUpdateExchange() {