|
|
@ -1,15 +1,12 @@ |
|
|
|
package com.epmet.mq; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants; |
|
|
|
import com.epmet.commons.rocketmq.messages.GroupAchievementMQMsg; |
|
|
|
import com.epmet.modules.group.service.StatsAchievementService; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
|
|
|
import org.apache.rocketmq.spring.core.RocketMQListener; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
/** |
|
|
|
* desc: 小组成就mq监听 |
|
|
@ -19,8 +16,8 @@ import org.springframework.stereotype.Component; |
|
|
|
* @version: 1.0 |
|
|
|
*/ |
|
|
|
@Slf4j |
|
|
|
@Component |
|
|
|
@RocketMQMessageListener(topic = "group_achievement", consumerGroup = ConsomerGroupConstants.GROUP_ACHIEVEMENT_COMPONENTS_GROUP) |
|
|
|
//@Component
|
|
|
|
//@RocketMQMessageListener(topic = "group_achievement", consumerGroup = ConsomerGroupConstants.GROUP_ACHIEVEMENT_COMPONENTS_GROUP)
|
|
|
|
public class GroupAchieventConsumerListener implements RocketMQListener<GroupAchievementMQMsg> { |
|
|
|
@Autowired |
|
|
|
private StatsAchievementService statsAchievementService; |
|
|
|