modify

Helius

2020-08-26 d8b9adf6a39ad94f22f473d11bc829a1cea5865f

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

@@ -42,6 +42,9 @@
    // 限价委托
    public static final String QUEUE_LIMIT = "QUEUE_LIMIT_NEW";

    // 委托平仓
    public static final String QUEUE_LIMIT_CLOSE = "QUEUE_LIMIT_CLOSE_NEW";

    // 爆仓队列
    public static final String QUEUE_COINOUT = "QUEUE_COINOUT_NEW";

@@ -71,6 +74,9 @@
    public static final String ROUTINGKEY_PRICEOPERATE = "ROUTINGKEY_PRICEOPERATE";
    // 平仓路由
    public static final String ROUTINGKEY_CLOSETRADE = "ROUTINGKEY_CLOSETRADE";

    // 委托平仓
    public static final String ROUTINGKEY_LIMIT_CLOSE = "ROUTINGKEY_LIMIT_CLOSE";

    @Resource
    private ConnectionFactory connectionFactory;
@@ -171,6 +177,16 @@
        return new Queue(QUEUE_LIMIT, true);
    }

    /**
     * 委托平仓
     *
     * @return
     */
    @Bean
    public Queue queueLimitClose() {
        return new Queue(QUEUE_LIMIT_CLOSE, true);
    }


    /**
     * 爆仓
@@ -254,6 +270,15 @@
        return BindingBuilder.bind(queueLimit()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_LIMIT);
    }

    /**
     * 委托平仓
     *
     * @return
     */
    @Bean
    public Binding bindingLimitClose() {
        return BindingBuilder.bind(queueLimitClose()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_LIMIT_CLOSE);
    }

    /**
     * 爆仓