modify

Helius

2021-05-21 24b53bf61f66428727e1dcbc4abf4320d8f48d8c

 src/main/java/com/xcong/excoin/rabbit/producer/OtcProducter.java

@@ -32,10 +32,8 @@

    public void sendDelayOrderMsg(String content) {
        log.info("-----{}", new Date());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_DELAY, RabbitMqConfig.ROUTING_KEY_DELAY, content, message -> {
            message.getMessageProperties().setExpiration(1000 * 60 + "");
            return message;
        });
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_DELAY, RabbitMqConfig.ROUTING_KEY_DELAY, content,correlationData );
    }

    @Override