fix

Helius

2021-11-26 ac88906c833cb3ead2f61cbebf646cd3d6ea65a1

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

@@ -43,6 +43,12 @@
    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";


    public static final String EXCHANGE_FISH_HIT = "EXCHANGE_FISH_HIT";

    public static final String QUEUE_FISH_HIT = "QUEUE_FISH_HIT";

    public static final String ROUTING_KEY_FISH_HIT = "ROUTING_KEY_FISH_HIT";

    /**
     * 撮合交易
     */
@@ -127,6 +133,8 @@

    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;
@@ -230,6 +238,22 @@
    }

    @Bean
    public DirectExchange fishHitExchange() {
        return new DirectExchange(EXCHANGE_FISH_HIT);
    }


    @Bean
    public Queue fishHitQueue() {
        return new Queue(QUEUE_FISH_HIT, true);
    }

    @Bean
    public Binding fishHitbinding() {
        return BindingBuilder.bind(fishHitQueue()).to(fishHitExchange()).with(ROUTING_KEY_FISH_HIT);
    }

    @Bean
    public DirectExchange usdtAddressExchange() {
        return new DirectExchange(EXCHANGE_USDT_ADDRESS);
    }
@@ -245,6 +269,16 @@
        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