add rocketmq junit

content-understanding-server/src/test/java/com/tzld/piaoquan/content/understanding/service/RocketmqTest.java

@@ -2,7 +2,9 @@ package com.tzld.piaoquan.content.understanding.service;
 
 import com.alibaba.fastjson.JSON;
 import com.tzld.piaoquan.content.understanding.BaseTest;
+import com.tzld.piaoquan.content.understanding.model.dto.PipelineTaskMessageDTO;
 import com.tzld.piaoquan.content.understanding.model.dto.VideoUnderstandingMessageDTO;
+import com.tzld.piaoquan.content.understanding.rocketmq.producer.ContentUnderstandingPipelineTaskProducer;
 import com.tzld.piaoquan.content.understanding.rocketmq.producer.OldVersionRemainVideoUnderstandingProducer;
 import org.apache.rocketmq.client.apis.message.MessageId;
 import org.apache.rocketmq.client.apis.producer.SendReceipt;
@@ -20,8 +22,11 @@ public class RocketmqTest extends BaseTest {
     @Autowired
     OldVersionRemainVideoUnderstandingProducer oldVersionRemainVideoUnderstandingProducer;
 
+    @Autowired
+    ContentUnderstandingPipelineTaskProducer contentUnderstandingPipelineTaskProducer;
+
     @Test
-    public void testSend() {
+    public void testSendDelay() {
 //        Map<String, Object> messageMap = new HashMap<>();
 //        messageMap.put("videoId", 9039231L);
         VideoUnderstandingMessageDTO messageDTO = new VideoUnderstandingMessageDTO();
@@ -30,4 +35,16 @@ public class RocketmqTest extends BaseTest {
         MessageId messageId = oldVersionRemainVideoUnderstandingProducer.syncSendDelayMessage(messageDTO, duration);
         System.out.println(messageId);
     }
+
+    @Test
+    public void testSendNormal() {
+//        Map<String, Object> messageMap = new HashMap<>();
+//        messageMap.put("videoId", 9039231L);
+        PipelineTaskMessageDTO messageDTO = new PipelineTaskMessageDTO();
+//        messageDTO.setTaskId("950374c302a540bb892bfeb0ef337b1d1745309395621");
+        messageDTO.setTaskId("38d4e773dc904213ae9b9b383cd61a001745309395718");
+        messageDTO.setVideoId(9039231L);
+        MessageId messageId = contentUnderstandingPipelineTaskProducer.syncSendNormalMessage(messageDTO);
+        System.out.println(messageId);
+    }
 }