|
|
@@ -116,6 +116,7 @@ public class RabbitMqListener {
|
|
|
return;
|
|
|
}
|
|
|
long deliveryTag = message.getMessageProperties().getDeliveryTag();
|
|
|
+ channel.basicAck(deliveryTag, false);
|
|
|
String msg = new String(message.getBody(), StandardCharsets.UTF_8);
|
|
|
BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
|
|
|
String messageId = message.getMessageProperties().getMessageId();
|
|
|
@@ -167,8 +168,6 @@ public class RabbitMqListener {
|
|
|
|
|
|
//计算完毕,将当前系统构建状态改为false
|
|
|
redisUtil.del(modelingKey);
|
|
|
-
|
|
|
- channel.basicAck(deliveryTag, false);
|
|
|
}
|
|
|
|
|
|
public void process(BuildSceneCallMessage message,BuildLog buildLog) {
|