55测试环境

KKSU

2024-04-17 829f629756e5402bcd3e9f6ef1f9c6dbffbabb11

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

@@ -32,15 +32,22 @@

    public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update";

    public static final String QUEUE_USDT_UPDATE = "queue_usdt_update";
    public static final String QUEUE_USDT_UPDATE = "queue_usdt_update_xch";

    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update";
    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update_xch";

    public static final String EXCHANGE_USDT_ADDRESS = "exchange_usdt_address";

    public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address";
    public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address_xch";

    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";
    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address_xch";

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

    public static final String QUEUE_XCH_AUTO_AGENT = "QUEUE_XCH_AUTO_AGENT";
    public static final String ROUTING_KEY_XCH_AUTO_AGENT = "ROUTING_KEY_XCH_AUTO_AGENT";


    /**
@@ -83,6 +90,11 @@
    public static final String QUEUE_FOLLOW_ORDER = "QUEUE_FOLLOW_ORDER";

    public static final String ROUTINGKEY_FOLLOW_ORDER = "ROUTINGKEY_FOLLOW_ORDER";

    // 跟单调整保证金
    public static final String QUEUE_FOLLOW_CHANGE_BOND = "QUEUE_FOLLOW_CHANGE_BOND";

    public static final String ROUTINGKEY_FOLLOW_CHANGE_BOND = "ROUTINGKEY_FOLLOW_CHANGE_BOND";

    // 开多止盈路由键
    public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO";
@@ -137,6 +149,31 @@
    }

    @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 xchAutoAgentQueue() {
        return new Queue(QUEUE_XCH_AUTO_AGENT, true);
    }

    @Bean
    public Binding xchAutoAgentBinding() {
        return BindingBuilder.bind(xchAutoAgentQueue()).to(xchExchange()).with(ROUTING_KEY_XCH_AUTO_AGENT);
    }

    @Bean
    public Queue testQueue() {
        return new Queue(QUEUE_TEST, true);
    }
@@ -149,7 +186,7 @@

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


@@ -165,7 +202,7 @@

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


@@ -305,6 +342,16 @@
    }

    @Bean
    public Queue queueFollowChangeBond() {
        return new Queue(QUEUE_FOLLOW_CHANGE_BOND, true);
    }

    @Bean
    public Binding bindingFollowChangeBond() {
        return BindingBuilder.bind(queueFollowChangeBond()).to(orderExchange()).with(ROUTINGKEY_FOLLOW_CHANGE_BOND);
    }

    @Bean
    public Binding bindingFollowOrder() {
        return BindingBuilder.bind(queueFollowOrder()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_FOLLOW_ORDER);
    }