|
@@ -47,7 +47,7 @@ public class RabbitMqListener {
|
|
|
log.info("场景升级开始,队列名:{},id:{},消息体:{}", upgradeToV4, correlationId, msg);
|
|
|
UpgradeBean upgradeBean = JSON.parseObject(msg, UpgradeBean.class);
|
|
|
//迁移数据
|
|
|
- sceneUpgradeToV4Service.upgrade(sceneProId);
|
|
|
+ sceneUpgradeToV4Service.upgrade(upgradeBean);
|
|
|
log.info("场景升级结束,队列名:{},id:{}", upgradeToV4, correlationId);
|
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
}
|