From 4f1ee115be474ff9b6621fa24a23c0fc2be8c963 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Sat, 27 Aug 2022 23:23:43 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java | 25 ------------------------- 1 files changed, 0 insertions(+), 25 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java index 031dad6..fcae1bf 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java +++ b/src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java @@ -33,31 +33,6 @@ } - public void sendOnlineTransfer(String batchNo) { - log.info("发送链上转账消息:{}", batchNo); - CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.ONLINE_TRANSFER.getExchange(), QueueEnum.ONLINE_TRANSFER.getRoute(), batchNo, correlationData); - } - - public void sendDitribProfit(Long id) { - log.info("发送滑点分配消息:{}", id); - CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.DISTRIB_PROFIT.getExchange(), QueueEnum.DISTRIB_PROFIT.getRoute(), id, correlationData); - } - - public void sendUserBuyReward(Long id) { - log.info("发送用户购买奖励消息:{}", id); - CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.USER_BUY_REWARD.getExchange(), QueueEnum.USER_BUY_REWARD.getRoute(), id, correlationData); - } - - public void sendNftBoxMsg(Long id) { - log.info("发送NFT盲盒消息:{}", id); - CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); - rabbitTemplate.convertAndSend(QueueEnum.NFT_BOX.getExchange(), QueueEnum.NFT_BOX.getRoute(), id, correlationData); - } - - public void sendAchieveTreeMsg(Long id) { log.info("发送业绩树消息:{}", id); CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); -- Gitblit v1.9.1