返回方法提交

src/main/java/com/zhiwei/source_forward/crawler/ContentCrawler.java

@@ -70,7 +70,7 @@ public class ContentCrawler {
         logger.info("当前处理 URL: {}", url);
         Request request = HttpRequestBuilder.newGetRequest(url, null);
         counter.increase();
-        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListeners(future -> {
+        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListener(future -> {
             if (future.isSuccess()) {
                 Response response = future.result();
                 try {

src/main/java/com/zhiwei/source_forward/crawler/MediaSelfSourceCrawler.java

@@ -83,7 +83,7 @@ public class MediaSelfSourceCrawler {
         logger.info("当前处理 URL: {}", url);
         Request request = HttpRequestBuilder.newGetRequest(url, null);
         counter.increase();
-        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListeners(future -> {
+        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListener(future -> {
             if (future.isSuccess()) {
                 Response response = future.result();
                 try {

src/main/java/com/zhiwei/source_forward/crawler/SourceForwardCrawler.java

@@ -55,7 +55,7 @@ public class SourceForwardCrawler {
         logger.info("当前处理 URL: {}", url);
         Request request = HttpRequestBuilder.newGetRequest(url, null);
         counter.increase();
-        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListeners(future -> {
+        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false).addListener(future -> {
             if (future.isSuccess()) {
                 Response response = future.result();
                 try {

src/main/java/com/zhiwei/source_forward/crawler/UrlLiveCrawler.java

@@ -57,7 +57,7 @@ public class UrlLiveCrawler {
         logger.info("当前处理 URL: {}", url);
         Request request = HttpRequestBuilder.newGetRequest(url, null);
         counter.increase();
-        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false,false).addListeners(future -> {
+        HttpBoot.asyncCall(request, ProxyClientUtil.getNATProxy(), false,false).addListener(future -> {
             if (future.isSuccess()) {
                 Response response = future.result();
                 try {