|
@@ -22,6 +22,7 @@ public class AbstrackBuildSceneListener implements IBuildSceneListener {
|
|
BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
|
|
BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
buildSceneService.buildScenePre(buildSceneMessage);
|
|
buildSceneService.buildScenePre(buildSceneMessage);
|
|
|
|
+ log.info("准备场景计算资源完成,队列名:{},id:{},消息体:{}", queueName, correlationId, msg);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -33,5 +34,6 @@ public class AbstrackBuildSceneListener implements IBuildSceneListener {
|
|
BuildSceneResultMqMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneResultMqMessage.class);
|
|
BuildSceneResultMqMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneResultMqMessage.class);
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
buildSceneService.buildScenePost(buildSceneMessage);
|
|
buildSceneService.buildScenePost(buildSceneMessage);
|
|
|
|
+ log.info("场景计算结果处理完成,队列名:{},id:{},消息体:{}", queueName, correlationId, msg);
|
|
}
|
|
}
|
|
}
|
|
}
|