modify

Helius

2021-05-27 9a968ba186af5280fcc29cc3eb04412eff204ba7

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

@@ -128,6 +128,9 @@
    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";

    @Resource
    private ConnectionFactory connectionFactory;

@@ -183,6 +186,16 @@
    }

    @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 testQueue() {
        return new Queue(QUEUE_TEST, true);
    }