Changeset 3921 for OAIHarvester

Timestamp:

10/31/13 10:04:35 (11 years ago)

Author:

oschonef

Message:

• make jobs cancellable

File:

• OAIHarvester/trunk/OAIHarvester/src/main/java/eu/clarin/cmdi/oai/harvester/impl/SimpleHarvester.java (modified) (4 diffs)

OAIHarvester/trunk/OAIHarvester/src/main/java/eu/clarin/cmdi/oai/harvester/impl/SimpleHarvester.java

@@ -62 +62 @@
                 try {
                     logger.debug("{}: ({}) waiting {} ...",
-                            job.getId(), job.getNetworkRetryCount(), delay); 
+                            job.getId(), job.getNetworkRetryCount(), delay);
                     /* add a few milliseconds, so we do not loop */
                     Thread.sleep(delay + 25);
@@ -70 +70 @@
             } // while (wait loop)
         } // while
+
+        synchronized (job) {
+            job.notifyAll();
+        } // synchronized (job)
     }
 
@@ -75 +79 @@
     @Override
     void doCancelJob(HarvestJobImpl job) throws HarvesterException {
-        throw new HarvesterException("cancel() is not supported");
     }
 
@@ -81 +84 @@
     @Override
     protected HarvestJob doFindJob(long id) throws HarvesterException {
-        throw new HarvesterException("findJob() is not supported");
+        return null;
     }