From bfbb03c514b9e60485ea13d5679e6af2e8aeb354 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 23 Nov 2022 09:44:23 +0800
Subject: [PATCH] 20221117
---
src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
index ad6292a..0d282f5 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
+++ b/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());
--
Gitblit v1.9.1