读取主题名 写错符号

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/TestController.java

@@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.common.constant.ConstantFilePath;
 import com.fdkankan.common.util.MatrixToImageWriterUtil;
 import com.fdkankan.mq.message.BaseBuildSceneMessage;
+import com.fdkankan.mq.message.BuildSceneMqMessage;
 import com.fdkankan.mq.message.BuildSceneResultMqMessage;
 import com.fdkankan.mq.message.MQBodyBean;
 import com.fdkankan.mq.util.RocketMQProducer;
@@ -157,11 +158,15 @@ public class TestController {
     @Autowired
     RocketMQProducer rocketMQProducer;
 
+    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
+    private String topicModelingA;
+
     @GetMapping("/testMQ")
-    public SendResult testMQ(){
-        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
-        SendResult sendResult = rocketMQProducer.syncSend("kkk", "tag2", UUID.randomUUID().toString(), body, 5000l);
-        return sendResult;
+    public void testMQ(){
+//        SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
+        BuildSceneMqMessage body = new BuildSceneMqMessage();
+        body.setPayStatus(1);
+        rocketMQProducer.sendOneWay(topicModelingA, body);
     }
 
     @GetMapping("/testAsynMQ")
@@ -176,9 +181,6 @@ public class TestController {
         rocketMQProducer.sendOneWay("qqq","tag6", UUID.randomUUID().toString(), body);
     }
 
-    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
-    private String topicModelingA;
-
     @RefreshScope
     @GetMapping("/testsenOnway1")
     public void testsenOnway1(){

4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/impl/SceneFileBuildServiceImpl.java

@@ -81,10 +81,10 @@ public class SceneFileBuildServiceImpl extends ServiceImpl<ISceneFileBuildMapper
     @Value("${unCalculated.company.ids:#{null}}")
     private String[] unCalculatedCompanyIds;
 
-    @Value("${rocketmq.build-scene.topicName:topic-modeling-a}")
+    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
     private String topicModelingA;
 
-    @Value("${rocketmq.build-scene:topicName:topic-laser-a}")
+    @Value("${rocketmq.build-scene.topicName.topic-laser-a}")
     private String topicLaserA;
 
     @Autowired