发送消息部分tag 改为 新版自定义线程池

rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/RoomMqMessageService.java

@@ -5,6 +5,7 @@ import com.red.circle.component.mq.service.FixedTopic;
 import com.red.circle.component.mq.service.SenderService;
 import com.red.circle.mq.business.model.event.room.LiveVoiceSessionEvent;
 import com.red.circle.mq.business.model.event.room.RoomVoiceCreateSuccessEvent;
+import com.red.circle.mq.rocket.business.service.MessageSenderService;
 import com.red.circle.mq.rocket.business.streams.CreateRoomSuccessSink;
 import com.red.circle.mq.rocket.business.streams.LiveVoiceSessionSink;
 import com.red.circle.tool.core.sequence.IdWorkerUtils;
@@ -20,13 +21,13 @@ import org.springframework.stereotype.Component;
 @RequiredArgsConstructor
 public class RoomMqMessageService {
 
-  private final SenderService senderService;
+  private final MessageSenderService messageSenderService;
 
   /**
    * 创建语音房间成功.
    */
   public void createVoiceRoomSuccess(RoomVoiceCreateSuccessEvent event) {
-    senderService.sendEventMessage(MessageEvent.builder()
+    messageSenderService.sendEventMessage(MessageEvent.builder()
         .consumeId(event.getId().toString())
         .topic(FixedTopic.RC_DEFAULT_APP_ORDINARY)
         .tag(CreateRoomSuccessSink.TAG)
@@ -38,7 +39,7 @@ public class RoomMqMessageService {
    * 直播会话连接.
    */
   public void liveSessionConnection(LiveVoiceSessionEvent event) {
-    senderService.sendEventMessage(MessageEvent.builder()
+    messageSenderService.sendEventMessage(MessageEvent.builder()
         .consumeId(IdWorkerUtils.getIdStr())
         .topic(FixedTopic.RC_DEFAULT_APP_ORDINARY)
         .tag(LiveVoiceSessionSink.TAG)

rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/UserMqMessageService.java

@@ -12,6 +12,7 @@ import com.red.circle.mq.business.model.event.user.LoginLoggerEvent;
 import com.red.circle.mq.business.model.event.user.UserCardApplyEvent;
 import com.red.circle.mq.business.model.event.user.UserHeartbeatEvent;
 import com.red.circle.mq.business.model.event.user.UserOnlineStatusEvent;
+import com.red.circle.mq.rocket.business.service.MessageSenderService;
 import com.red.circle.mq.rocket.business.streams.AccountBeautifulNumberSink;
 import com.red.circle.mq.rocket.business.streams.BadgeCheckSink;
 import com.red.circle.mq.rocket.business.streams.BadgeOperateSink;
@@ -24,6 +25,7 @@ import com.red.circle.mq.rocket.business.streams.UserHeartbeatSink;
 import com.red.circle.tool.core.sequence.IdWorkerUtils;
 import java.sql.Timestamp;
 import lombok.RequiredArgsConstructor;
+import org.springframework.context.MessageSource;
 import org.springframework.stereotype.Component;
 
 /**
@@ -34,6 +36,7 @@ import org.springframework.stereotype.Component;
 public class UserMqMessageService {
 
   private final SenderService senderService;
+  private final MessageSenderService messageSenderService;
 
   /**
    * 登陆注册.
@@ -117,7 +120,7 @@ public class UserMqMessageService {
    * 发送用户心跳事件.
    */
   public void sendUserHeartbeat(UserHeartbeatEvent event) {
-    senderService.sendEventMessage(MessageEvent.builder()
+    messageSenderService.sendEventMessage(MessageEvent.builder()
         .consumeId(IdWorkerUtils.getIdStr())
         .topic(FixedTopic.RC_DEFAULT_APP_ORDINARY)
         .tag(UserHeartbeatSink.TAG)

rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/WalletMqMessageService.java

@@ -4,6 +4,7 @@ import com.red.circle.component.mq.MessageEvent;
 import com.red.circle.component.mq.service.FixedTopic;
 import com.red.circle.component.mq.service.SenderService;
 import com.red.circle.mq.business.model.event.wallet.WalletReceiptSyncEvent;
+import com.red.circle.mq.rocket.business.service.MessageSenderService;
 import com.red.circle.mq.rocket.business.streams.WalletAssetGoldSyncSinkV2;
 import java.util.Objects;
 import lombok.RequiredArgsConstructor;
@@ -19,12 +20,13 @@ import org.springframework.stereotype.Service;
 public class WalletMqMessageService {
 
   private final SenderService senderService;
+  private final MessageSenderService messageSenderService;
 
   /**
    * 钱包同步消息.
    */
   public void sync(WalletReceiptSyncEvent event) {
-    senderService.sendEventMessage(MessageEvent.builder()
+    messageSenderService.sendEventMessage(MessageEvent.builder()
         .consumeId(Objects.toString(event.getAssetRecordId()))
         .topic(FixedTopic.RC_DEFAULT_APP_ORDINARY)
         .tag(WalletAssetGoldSyncSinkV2.TAG)

rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/common/gift/GameLuckyGiftCommon.java

@@ -20,6 +20,7 @@ import com.red.circle.framework.core.asserts.ResponseAssert;
 import com.red.circle.framework.core.dto.ReqSysOrigin;
 import com.red.circle.mq.business.model.event.gift.GameLuckyGiftBusinessEvent;
 import com.red.circle.mq.business.model.event.gift.GameLuckyGiftUser;
+import com.red.circle.mq.rocket.business.service.MessageSenderService;
 import com.red.circle.mq.rocket.business.streams.GameLuckyGiftBusinessSink;
 import com.red.circle.other.app.convertor.user.UserProfileAppConvertor;
 import com.red.circle.other.app.dto.clientobject.game.GameLuckyGiftMsgCO;
@@ -86,7 +87,7 @@ import org.springframework.stereotype.Component;
 @RequiredArgsConstructor
 public class GameLuckyGiftCommon {
 
-  private final SenderService senderService;
+  private final MessageSenderService senderService;
   private final ImGroupClient imGroupClient;
   private final WalletGoldClient walletGoldClient;
   private final GiftCacheService giftCacheService;