Helius
2021-06-17 bc1350318fc28f23b22a07d2e41c5e00c504ddaa
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -127,6 +127,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;
@@ -245,6 +247,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