|
@@ -724,7 +724,8 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
|
|
|
}
|
|
|
String homePath = dataSource.replace("/mnt/data","home");
|
|
|
SceneRestStoreVo sceneRestStoreVo = new SceneRestStoreVo(num,sceneColdStorage.getColdBucket(),sceneColdStorage.getBucket(),homePath);
|
|
|
- rabbitMqProducer.sendByWorkQueue(MqQueueUtil.sceneRestoreQueue,sceneRestStoreVo);
|
|
|
+ Map<String, Object> map = BeanUtil.beanToMap(sceneRestStoreVo);
|
|
|
+ rabbitMqProducer.sendByWorkQueue(MqQueueUtil.sceneRestoreQueue,map);
|
|
|
//threadService.checkRestore(num,sceneColdStorage.getColdBucket(),sceneColdStorage.getBucket(),homePath);
|
|
|
}
|
|
|
|