diff --git a/rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/TeamSalaryMqMessage.java b/rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/TeamSalaryMqMessage.java index 6732c83f..a745e6dc 100644 --- a/rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/TeamSalaryMqMessage.java +++ b/rc-common-business/common-business-mq/business-rocketmq/src/main/java/com/red/circle/mq/rocket/business/producer/TeamSalaryMqMessage.java @@ -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; /** * 团队工资实时统计 - 业务处理.