modify

Helius

2021-05-13 1b44a9a25a51324dba8e8640cb405440f2cf7d48

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

@@ -42,6 +42,10 @@

    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";

    public static final String QUEUE_XCH_USDT_PRIFIT = "QUEUE_XCH_USDT_PRIFIT";
    public static final String ROUTING_KEE_XCH_USDT_PRIFIT = "ROUTING_KEE_XCH_USDT_PRIFIT";
    public static final String EXCHANGE_XCH = "EXCHANGE_XCH";


    /**
     * 撮合交易
@@ -142,6 +146,21 @@
    }

    @Bean
    public DirectExchange xchExchange() {
        return new DirectExchange(EXCHANGE_XCH);
    }

    @Bean
    public Queue xchUsdtProfitQueue() {
        return new Queue(QUEUE_XCH_USDT_PRIFIT, true);
    }

    @Bean
    public Binding xchUsdtProfitBinding() {
        return BindingBuilder.bind(xchUsdtProfitQueue()).to(xchExchange()).with(ROUTING_KEE_XCH_USDT_PRIFIT);
    }

    @Bean
    public Queue testQueue() {
        return new Queue(QUEUE_TEST, true);
    }