modify

Helius

2021-06-08 30c1c9d16a57d2bbc7cd1511d02c5ddcc6a143f6

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

@@ -128,6 +128,16 @@
    public static final String QUEUE_DELAY = "queue.delay";
    public static final String EXCHANGE_DELAY = "exchange.delay";

    public static final String QUEUE_MSG_HISTORY = "queue_msg_history";
    public static final String ROUTING_KEY_MSG_HISTORY = "routing_key_msg_history";

    public static final String QUEUE_TRC20_BLOCK = "QUEUE_TRC20_BLOCK";
    public static final String ROUTING_TRC20_BLOCK = "ROUTING_TRC20_BLOCK";


    public static final String QUEUE_ORDER_RETURN = "QUEUE_ORDER_RETURN";
    public static final String ROUTING_ORDER_RETURN = "ROUTING_ORDER_RETURN";

    @Resource
    private ConnectionFactory connectionFactory;

@@ -163,6 +173,7 @@
        params.put("x-dead-letter-exchange", EXCHANGE_DELAY);
        // x-dead-letter-routing-key 声明了这些死信在转发时携带的 routing-key 名称。
        params.put("x-dead-letter-routing-key", ROUTING_KEY_DELAY);
//        params.put("x-message-ttl", 6000);
        return new Queue(QUEUE_DELAY, true, false, false, params);
    }

@@ -182,6 +193,38 @@
    }

    @Bean
    public Queue msgHistoryQueue() {
        return new Queue(QUEUE_MSG_HISTORY);
    }

    @Bean
    public Binding msgHistoryBinding() {
        return BindingBuilder.bind(msgHistoryQueue()).to(defaultExchange()).with(ROUTING_KEY_MSG_HISTORY);
    }

    @Bean
    public Queue orderReturnQueue() {
        return new Queue(QUEUE_ORDER_RETURN);
    }

    @Bean
    public Binding orderReturnBinding() {
        return BindingBuilder.bind(orderReturnQueue()).to(defaultExchange()).with(ROUTING_ORDER_RETURN);
    }


    @Bean
    public Queue trc20Queue() {
        return new Queue(QUEUE_TRC20_BLOCK);
    }

    @Bean
    public Binding trc20Binding() {
        return BindingBuilder.bind(trc20Queue()).to(defaultExchange()).with(ROUTING_TRC20_BLOCK);
    }


    @Bean
    public Queue testQueue() {
        return new Queue(QUEUE_TEST, true);
    }