From c085a738f70f57d7f69b811bd3d1e31cd8f72456 Mon Sep 17 00:00:00 2001
From: wuxicheng <1441859745@qq.com>
Date: Sun, 21 May 2023 00:50:47 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../order/service/impl/OrderMqMessageRecordServiceImpl.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
index a2c3f8a..055e3f4 100644
--- a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
+++ b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
@@ -106,11 +106,9 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
      */
     @Transactional
     public <T> OrderMqMessageRecord saveMessageRecord(String topic, String tag, T message){
-        RocketMQTemplate rocketMQTemplate = rocketMQEnhanceTemplate.getTemplate();
-        String consumerGroup = rocketMQTemplate.getConsumer().getConsumerGroup();
         OrderMqMessageRecord orderMqMessageRecord = new OrderMqMessageRecord();
         orderMqMessageRecord.setStatus(EnumMessageStatus.PROCESS);
-        orderMqMessageRecord.setConsumerGroupName(consumerGroup);
+        orderMqMessageRecord.setConsumerGroupName(topic);
         orderMqMessageRecord.setTopic(topic);
         orderMqMessageRecord.setTag(tag);
         orderMqMessageRecord.setCreateTime(new Date());