Преглед изворни кода

fixed task loss when priority queue is full

ehlxr пре 1 година
родитељ
комит
b839b162c3
1 измењених фајлова са 30 додато и 44 уклоњено
  1. 30 44
      etl-core/src/main/java/com/tzld/crawler/etl/model/vo/CrawlerEtlParam.java

+ 30 - 44
etl-core/src/main/java/com/tzld/crawler/etl/model/vo/CrawlerEtlParam.java

@@ -127,10 +127,36 @@ public class CrawlerEtlParam {
      */
     private String messageId;
 
-    /**
-     * the handle of message, used to ack
-     */
-    private String receiptHandle;
+    @Override
+    public String toString() {
+        return "CrawlerEtlParam{" +
+                "userId=" + userId +
+                ", outUserId='" + outUserId + '\'' +
+                ", userName='" + userName + '\'' +
+                ", avatarUrl='" + avatarUrl + '\'' +
+                ", platform='" + platform + '\'' +
+                ", strategy='" + strategy + '\'' +
+                ", outVideoId='" + outVideoId + '\'' +
+                ", videoTitle='" + videoTitle + '\'' +
+                ", coverUrl='" + coverUrl + '\'' +
+                ", videoUrl='" + videoUrl + '\'' +
+                ", duration=" + duration +
+                ", publishTime='" + publishTime + '\'' +
+                ", playCnt=" + playCnt +
+                ", likeCnt=" + likeCnt +
+                ", shareCnt=" + shareCnt +
+                ", collectionCnt=" + collectionCnt +
+                ", commentCnt=" + commentCnt +
+                ", crawlerRule='" + crawlerRule + '\'' +
+                ", width=" + width +
+                ", height=" + height +
+                ", strategyType='" + strategyType + '\'' +
+                ", coverOssPath='" + coverOssPath + '\'' +
+                ", videoOssPath='" + videoOssPath + '\'' +
+                ", audioUrl='" + audioUrl + '\'' +
+                ", messageId='" + messageId + '\'' +
+                '}';
+    }
 
     public String getMessageId() {
         return messageId;
@@ -331,44 +357,4 @@ public class CrawlerEtlParam {
     public void setHeight(Integer height) {
         this.height = height;
     }
-
-    @Override
-    public String toString() {
-        return "CrawlerEtlParam{" +
-                "userId=" + userId +
-                ", outUserId='" + outUserId + '\'' +
-                ", userName='" + userName + '\'' +
-                ", avatarUrl='" + avatarUrl + '\'' +
-                ", platform='" + platform + '\'' +
-                ", strategy='" + strategy + '\'' +
-                ", outVideoId='" + outVideoId + '\'' +
-                ", videoTitle='" + videoTitle + '\'' +
-                ", coverUrl='" + coverUrl + '\'' +
-                ", videoUrl='" + videoUrl + '\'' +
-                ", duration=" + duration +
-                ", publishTime='" + publishTime + '\'' +
-                ", playCnt=" + playCnt +
-                ", likeCnt=" + likeCnt +
-                ", shareCnt=" + shareCnt +
-                ", collectionCnt=" + collectionCnt +
-                ", commentCnt=" + commentCnt +
-                ", crawlerRule='" + crawlerRule + '\'' +
-                ", width=" + width +
-                ", height=" + height +
-                ", strategyType='" + strategyType + '\'' +
-                ", coverOssPath='" + coverOssPath + '\'' +
-                ", videoOssPath='" + videoOssPath + '\'' +
-                ", audioUrl='" + audioUrl + '\'' +
-                ", messageId='" + messageId + '\'' +
-                ", receiptHandle='" + receiptHandle + '\'' +
-                '}';
-    }
-
-    public String getReceiptHandle() {
-        return receiptHandle;
-    }
-
-    public void setReceiptHandle(String receiptHandle) {
-        this.receiptHandle = receiptHandle;
-    }
 }