|
@@ -1,6 +1,8 @@
|
|
|
package com.fdkankan;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.fdkankan.common.rocketmq.producer.MqSendMessage;
|
|
|
+import com.fdkankan.mq.message.BuildSceneMqMessage;
|
|
|
import com.fdkankan.scene.service.IFolderService;
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -23,7 +25,8 @@ class SceneApplicationTests {
|
|
|
|
|
|
@Test
|
|
|
public void test(){
|
|
|
- mqSendMessage.sendMessage("test");
|
|
|
+ BuildSceneMqMessage message = new BuildSceneMqMessage();
|
|
|
+ mqSendMessage.sendMessage(JSONObject.toJSONString(message));
|
|
|
}
|
|
|
|
|
|
}
|