diff --git a/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java b/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
index d4013da54c992234ac97e8839d066185c2abd063..289307d9714b9744adf252376066b49f6c35a462 100644
--- a/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
+++ b/datamover/source/java/ch/systemsx/cisd/datamover/IncomingProcessor.java
@@ -86,7 +86,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
         this.bufferDirs = bufferDirs;
     }
 
-
     public TimerTask createRecoverableTimerTask()
     {
         return new IncomingProcessorRecoveryTask();
@@ -217,7 +216,6 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
             {
                 recoverIncomingInProgress(bufferDirs.getCopyInProgressDir(), bufferDirs.getCopyCompleteDir());
             }
-            recoverIncomingCopyComplete(bufferDirs.getCopyCompleteDir());
             if (operationLog.isDebugEnabled())
             {
                 operationLog.debug("Recovery is finished.");
@@ -281,15 +279,5 @@ public class IncomingProcessor implements IRecoverableTimerTaskFactory
                 }
             }
         }
-
-        // schedule processing of all resources which were previously copied
-        private void recoverIncomingCopyComplete(File copyCompleteDir)
-        {
-            final File[] files = incomingReadOperations.tryListFiles(copyCompleteDir, errorLog);
-            if (files == null || files.length == 0)
-            {
-                return; // directory is empty, no recovery is needed
-            }
-        }
     }
 }