hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mq替换为自定义mq处理

Browse Source
This commit is contained in:
tianfeng 2026-01-01 01:52:54 +08:00
parent 9b81950fe1
commit fa57473d5f
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/TeamSalaryMqMessage.java
View File

@ -9,6 +9,7 @@ import com.red.circle.mq.business.model.event.team.TeamExchangeSurplusTargetEven
import com.red.circle.mq.business.model.event.team.TeamSalaryCountEvent;
import com.red.circle.mq.business.model.event.team.TeamSalaryPaymentEvent;
import com.red.circle.mq.business.model.event.team.TeamSalaryRevokeEvent;
import com.red.circle.mq.rocket.business.service.MessageSenderService;
import com.red.circle.mq.rocket.business.streams.TeamBillSettleSink;
import com.red.circle.mq.rocket.business.streams.TeamExchangeSurplusTargetSink;
import com.red.circle.mq.rocket.business.streams.TeamSalaryCountSink;
@ -38,7 +39,7 @@ import org.springframework.stereotype.Component;
public class
TeamSalaryMqMessage {
private final SenderService senderService;
private final MessageSenderService senderService;
/**
* 团队工资实时统计 - 业务处理.