将监听充值新建一个项目

KKSU

2024-06-07 c7720fa1218e18a768b83eb154b2c4f0909b1b81

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

@@ -49,4 +49,15 @@
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.WITHDRAW_FEE.getExchange(), QueueEnum.WITHDRAW_FEE.getRoute(), data, correlationData);
    }

    /**
     * 发送手续费分发消息
     *
     * @param id
     */
    public void sendFeeDistributeMsg(Long id) {
        log.info("发送手续费分发消息:{}", id);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.DISTRIB_PROFIT.getExchange(), QueueEnum.DISTRIB_PROFIT.getRoute(), id, correlationData);
    }
}