Upgrade URLFrontier to v2.1

HHN · Jun 7, 2022 · 9bd4796 · 9bd4796
1 parent 913d893
commit 9bd4796
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...-frontier-urlfrontier/src/main/java/de/hshn/mi/crawler4j/frontier/URLFrontierAdapter.java b/...-frontier-urlfrontier/src/main/java/de/hshn/mi/crawler4j/frontier/URLFrontierAdapter.java
@@ -76,10 +76,10 @@ public void scheduleAll(List<WebURL> urls) {
         final AtomicBoolean completed = new AtomicBoolean(false);
         int sent = 0;
 
-        StreamObserver<Urlfrontier.String> responseObserver =
+        StreamObserver<crawlercommons.urlfrontier.Urlfrontier.AckMessage> responseObserver =
                 new StreamObserver<>() {
                     @Override
-                    public void onNext(crawlercommons.urlfrontier.Urlfrontier.String value) {
+                    public void onNext(crawlercommons.urlfrontier.Urlfrontier.AckMessage value) {
                         // receives confirmation that the value has been received
                         acked.addAndGet(1);
                     }
@@ -202,10 +202,10 @@ public void setProcessed(WebURL webURL) {
         if (webURL instanceof URLFrontierWebURLImpl) {
             URLFrontierWebURLImpl url = (URLFrontierWebURLImpl) webURL;
 
-            final StreamObserver<Urlfrontier.String> responseObserver =
+            final StreamObserver<crawlercommons.urlfrontier.Urlfrontier.AckMessage> responseObserver =
                     new StreamObserver<>() {
                         @Override
-                        public void onNext(crawlercommons.urlfrontier.Urlfrontier.String value) {
+                        public void onNext(crawlercommons.urlfrontier.Urlfrontier.AckMessage value) {
                             // receives confirmation that the value has been received
                             completedPages.addAndGet(1);
                         }