更新消息队列监听器架构2.0

src/main/java/cn/meteor/beyondclouds/core/listener/DataItemChangeConsumer.java

@@ -9,6 +9,7 @@ import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
 import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.Collection;
@@ -21,6 +22,7 @@ import java.util.Optional;
  * 监听本系统所有的数据更新 操作：更新操作包括
  * @author meteor
  */
+@Component
 @Slf4j
 public class DataItemChangeConsumer implements TopicConsumer, ApplicationContextAware {
 

src/main/java/cn/meteor/beyondclouds/modules/question/listener/UserInfoChangeListener.java

+package cn.meteor.beyondclouds.modules.question.listener;
+
+import cn.meteor.beyondclouds.core.listener.DataItemChangeListener;
+import cn.meteor.beyondclouds.modules.queue.message.DataItemChangeMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * 用户信息更新监听器
+ * @author meteor
+ */
+@Slf4j
+@Component("questionUserInfoChangeListener")
+public class UserInfoChangeListener extends DataItemChangeListener {
+
+    @Override
+    public void onUserAvatarUpdate(DataItemChangeMessage dataItemChangeMessage) {
+        log.debug("question-用户头像更新：{}", dataItemChangeMessage);
+    }
+}