星级矩阵

KKSU

2024-06-13 6a0baf02bb1cc4b7d1d0e9d796ead2218ed9c824

 src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java

@@ -76,4 +76,9 @@
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.TFC_NODE_PERK.getExchange(), QueueEnum.TFC_NODE_PERK.getRoute(), id, correlationData);
    }
    public void sendNodeMsg(Long id) {
        log.info("发送复投:{}", id);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.TFC_NODE_AGAIN.getExchange(), QueueEnum.TFC_NODE_AGAIN.getRoute(), id, correlationData);
    }
}