瀏覽代碼

消费端, 异常记录状态

wuweihao 4 年之前
父節點
當前提交
e074e49d5a
共有 1 個文件被更改,包括 6 次插入0 次删除
  1. 6 0
      720yun_fd_consumer/src/main/java/com/gis/listener/Fd720Listener.java

+ 6 - 0
720yun_fd_consumer/src/main/java/com/gis/listener/Fd720Listener.java

@@ -15,6 +15,7 @@ import org.springframework.stereotype.Component;
 
 import java.io.PrintWriter;
 import java.io.StringWriter;
+import java.util.Date;
 import java.util.concurrent.*;
 
 
@@ -88,6 +89,10 @@ public class Fd720Listener {
             log.info("任务成功返回: " + obj);
         } catch (InterruptedException e) {
             e.printStackTrace();
+            entity.setStatus(2);
+            StringWriter trace=new StringWriter();
+            log.error(trace.toString());
+            log.error("异常了 InterruptedException");
         } catch (ExecutionException e) {
             e.printStackTrace();
             StringWriter trace=new StringWriter();
@@ -106,6 +111,7 @@ public class Fd720Listener {
             entity.setStatus(2);
             future.cancel(true);
         } finally {
+            entity.setUpdateTime(new Date());
             fodderMapper.updateByPrimaryKey(entity);
         }
     }