Bladeren bron

修改延时队列为15分钟执行

xiewenjie 3 jaren geleden
bovenliggende
commit
b4eba9ca7d

+ 1 - 1
sxz-core/src/main/java/com/fdkk/sxz/webApi/controller/ManagerController.java

@@ -714,7 +714,7 @@ public class ManagerController extends BaseController {
                 ".obj", ".fdage") + ":;" + modelUploadEntity.getFileId();
         rabbitTemplate.convertAndSend(TopicRabbitConfig.DELAY_EXCHANGE, TopicRabbitConfig.MVIEW, messageStr, message -> {
             // 设置过期时间
-            message.getMessageProperties().setDelay(1800000);
+            message.getMessageProperties().setDelay(900000);
             return message;
         });
         //保存模型位置信息

+ 1 - 1
sxz-core/src/main/java/com/fdkk/sxz/webApi/service/impl/ComponentModelUploadServiceImpl.java

@@ -175,7 +175,7 @@ public class ComponentModelUploadServiceImpl extends BaseServiceImpl<IComponentM
                         rabbitTemplate.convertAndSend(TopicRabbitConfig.DELAY_EXCHANGE, TopicRabbitConfig.MVIEW,
                                 messageStr, message -> {
                                     // 设置过期时间
-                                    message.getMessageProperties().setDelay(1800000);
+                                    message.getMessageProperties().setDelay(900000);
                                     return message;
                                 });
                         componentModel.setPartsDetailId(customComponentEntity.getId());

+ 1 - 1
sxz-core/src/main/java/com/fdkk/sxz/webApi/service/impl/ModelUploadServiceImpl.java

@@ -234,7 +234,7 @@ public class ModelUploadServiceImpl extends BaseServiceImpl<IModelUploadMapper,
                                     rabbitTemplate.convertAndSend(TopicRabbitConfig.DELAY_EXCHANGE, TopicRabbitConfig.MVIEW,
                                             messageStr, message -> {
                                                 // 设置过期时间
-                                                message.getMessageProperties().setDelay(1800000);
+                                                message.getMessageProperties().setDelay(900000);
                                                 return message;
                                             });
                                 }