modify

Helius

2021-06-15 2e3db6b70d8441f11fbbd60999ab8fe8cc167fa0

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

@@ -36,6 +36,12 @@

    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update";

    public static final String EXCHANGE_USDT_ADDRESS = "exchange_usdt_address";

    public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address";

    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";


    /**
     * 撮合交易
@@ -115,6 +121,14 @@

    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";

    public static final String QUEUE_TRC20_BLOCK = "QUEUE_TRC20_BLOCK";
    public static final String ROUTING_TRC20_BLOCK = "ROUTING_TRC20_BLOCK";

    @Resource
    private ConnectionFactory connectionFactory;
@@ -183,6 +197,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
@@ -201,6 +231,32 @@
        return BindingBuilder.bind(usdtUpdateQueue()).to(usdtUpdateExchange()).with(ROUTING_KEY_USDT_UPDATE);
    }

    @Bean
    public DirectExchange usdtAddressExchange() {
        return new DirectExchange(EXCHANGE_USDT_ADDRESS);
    }


    @Bean
    public Queue usdtAddressQueue() {
        return new Queue(QUEUE_USDT_ADDRESS, true);
    }

    @Bean
    public Binding usdtAddressbinding() {
        return BindingBuilder.bind(usdtAddressQueue()).to(usdtAddressExchange()).with(ROUTING_KEY_USDT_ADDRESS);
    }

    @Bean
    public Queue trc20Queue() {
        return new Queue(QUEUE_TRC20_BLOCK);
    }

    @Bean
    public Binding trc20Binding() {
        return BindingBuilder.bind(trc20Queue()).to(defaultExchange()).with(ROUTING_TRC20_BLOCK);
    }


    /**
     * 交换器A 可以继续添加交换器B C