优化usdt同步

zainali5120

2020-10-09 f0de669a7d37d15f841952e41834ecca07aa1fc5

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

@@ -29,6 +29,14 @@

    public static final String EXCHANGE_A = "biue-exchange-A";


    public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update";

    public static final String QUEUE_USDT_UPDATE = "queue_usdt_update";

    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update";


    /**
     * 撮合交易
     */
@@ -89,6 +97,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;

@@ -121,6 +136,23 @@
    @Bean
    public Binding binding() {
        return BindingBuilder.bind(testQueue()).to(defaultExchange()).with(ROUTING_KEY_TEST);
    }


   @Bean
    public DirectExchange usdtUpdateExchange() {
        return new DirectExchange(EXCHANGE_USDT_UPDATE);
    }


    @Bean
    public Queue usdtUpdateQueue() {
        return new Queue(QUEUE_USDT_UPDATE, true);
    }

    @Bean
    public Binding usdtUpdatebinding() {
        return BindingBuilder.bind(usdtUpdateQueue()).to(usdtUpdateExchange()).with(ROUTING_KEY_USDT_UPDATE);
    }


@@ -351,4 +383,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);
    }

}