|
|
@@ -13,6 +13,8 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
+import org.springframework.messaging.Message;
|
|
|
+import org.springframework.messaging.support.MessageBuilder;
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestMethod;
|
|
|
@@ -25,7 +27,7 @@ import org.springframework.web.bind.annotation.RestController;
|
|
|
@Slf4j
|
|
|
@RestController
|
|
|
@RequestMapping("/change/queue")
|
|
|
-@Api(tags = "数据迁移模块")
|
|
|
+@Api(tags = "队列转发模块")
|
|
|
public class QueueController {
|
|
|
|
|
|
@Autowired
|
|
|
@@ -44,7 +46,8 @@ public class QueueController {
|
|
|
@AroundLog(name = "数据处理任务接收")
|
|
|
public Result dataHandle(@RequestBody RequestQueue params) {
|
|
|
QueueController.log.info("数据处理任务接收:{}", params);
|
|
|
- rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPICE, TopicRabbitConfig.MODEL_BIZ, params);
|
|
|
+ Message message = MessageBuilder.withPayload(params).build();
|
|
|
+ rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPICE, TopicRabbitConfig.MODEL_BIZ_3D, message);
|
|
|
return Result.success("处理结果");
|
|
|
}
|
|
|
|
xiewenjie