xiaoyong931011
2022-11-14 5c53b4e1e7dc2bae956332a0dc446992725c80bb
src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
@@ -27,6 +27,12 @@
        rabbitTemplate.setConfirmCallback(this);
    }
    public void sendMemberCoinInside(Long withdrawId) {
        log.info("发送用户内部转账的消息:{}", withdrawId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(RabbitMqConfig.MEMBER_COIN_INSIDE_EXCHANGE, RabbitMqConfig.MEMBER_COIN_INSIDE__ROUTE_KEY, withdrawId, correlationData);
    }
    public void sendOnHookEnd(Long orderId) {
        log.info("发送用户结束挂机的消息:{}", orderId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());