svn commit: r1623251 - in /manifoldcf/trunk: CHANGES.txt framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java

[kwright]

Author: kwright
Date: Mon Sep  8 00:45:53 2014
New Revision: 1623251

URL: http://svn.apache.org/r1623251
Log:
Fix for CONNECTORS-1024.

Modified:
    manifoldcf/trunk/CHANGES.txt
    
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java

Modified: manifoldcf/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/CHANGES.txt?rev=1623251&r1=1623250&r2=1623251&view=diff
==============================================================================
--- manifoldcf/trunk/CHANGES.txt (original)
+++ manifoldcf/trunk/CHANGES.txt Mon Sep  8 00:45:53 2014
@@ -3,6 +3,10 @@ $Id$
 
 ======================= 2.0-dev =====================
 
+CONNECTORS-1024: Non-null components always failed due to a
+null pointer exception.
+(Karl Wright)
+
 CONNECTORS-1023: Fix Alfresco tests.  They don't yet succeed, but
 at least they run, and the connector can communicate with Alfresco.
 (Karl Wright)

Modified: 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java?rev=1623251&r1=1623250&r2=1623251&view=diff
==============================================================================
--- 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
 (original)
+++ 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/system/WorkerThread.java
 Mon Sep  8 00:45:53 2014
@@ -2033,7 +2033,7 @@ public class WorkerThread extends Thread
     protected void checkMultipleDispositions(String documentIdentifier, String 
componentIdentifier, String componentIdentifierHash)
     {
       if (abortSet.contains(documentIdentifier))
-        throw new IllegalStateException("Multiple document dispositions not 
allowed: Abort cannot be combiend with component disposition; document 
'"+documentIdentifier+"'");
+        throw new IllegalStateException("Multiple document dispositions not 
allowed: Abort cannot be combined with component disposition; document 
'"+documentIdentifier+"'");
       if (documentDeletedSet.contains(documentIdentifier))
         throw new IllegalStateException("Multiple document dispositions not 
allowed: Document delete cannot be combined with component disposition; 
document '"+documentIdentifier+"'");
       if (componentIdentifierHash == null)
@@ -2045,7 +2045,7 @@ public class WorkerThread extends Thread
       else
       {
         Set<String> components = touchedComponentSet.get(documentIdentifier);
-        if (components.contains(componentIdentifierHash))
+        if (components != null && components.contains(componentIdentifierHash))
           throw new IllegalStateException("Multiple document component 
dispositions not allowed: document '"+documentIdentifier+"', component 
'"+componentIdentifier+"'");
       }
     }