mq抽离 redis抽离

4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/BuildSceneMQListener.java

@@ -57,7 +57,7 @@ import static com.fdkankan.modeling.push.PushMessageConfig.*;
 @RocketMQMessageListener(
         consumerGroup = "${rocketmq.consumer.group}",
         topic = "${rocketmq.build-scene.topicName.topic-modeling-a}",
-        messageModel = MessageModel.BROADCASTING)
+        messageModel = MessageModel.CLUSTERING)
 public class BuildSceneMQListener implements RocketMQListener<String> {
 
     @Value("${rocketmq.consumer.group}")