xiaoyong931011
2021-03-04 c0fac904e85b0b0131cde4c6b7f1e8de9f095089
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -76,6 +76,9 @@
    // 全仓爆仓
    public static final String QUEUE_WHOLE_BOMB = "QUEUE_WHOLE_BOMB_NEW";
    // 全仓价格操作
    public static final String QUEUE_WHOLE_PRICE = "QUEUE_WHOLE_PRCE";
    // 开多止盈路由键
    public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO";
@@ -102,6 +105,9 @@
    // 全仓爆仓
    public static final String ROUTINGKEY_WHOLE_BOMB = "ROUTINGKEY_WHOLE_BOMB";
    // 全仓价格操作
    public static final String ROUTINGKEY_WHOLE_PRICE = "ROUTINGKEY_WHOLE_PRICE";
    @Resource
    private ConnectionFactory connectionFactory;
@@ -276,6 +282,10 @@
        return new Queue(QUEUE_CLOSETRADE, true);
    }
    @Bean
    public Queue queueWholePrice() {
        return new Queue(QUEUE_WHOLE_PRICE, true);
    }
    /**
     * 全仓爆仓
     * @return
@@ -285,6 +295,12 @@
        return new Queue(QUEUE_WHOLE_BOMB, true);
    }
    @Bean
    public Binding bindingWholePrice() {
        return BindingBuilder.bind(queueWholePrice()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_WHOLE_PRICE);
    }
    /**
     * 开多止盈
     *