1

src/main/java/com/fdkankan/manage/mq/consumer/SceneRestStoreConsumer.java

@@ -87,11 +87,11 @@ public class SceneRestStoreConsumer {
             sceneColdStorageLogService.saveLog(num,folderName);
             sceneProService.restStoreSuccess(num);
             redisUtil.del(redisKey);
-
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         }catch (Exception e){
             log.info("scene-restStore----消费失败",e);
         }finally {
-            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+
         }
 
     }