Author: kwright
Date: Mon Jul 30 18:57:48 2018
New Revision: 1837084

URL: http://svn.apache.org/viewvc?rev=1837084&view=rev
Log:
Fix for CONNECTORS-1520.

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

Modified: manifoldcf/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/CHANGES.txt?rev=1837084&r1=1837083&r2=1837084&view=diff
==============================================================================
--- manifoldcf/trunk/CHANGES.txt (original)
+++ manifoldcf/trunk/CHANGES.txt Mon Jul 30 18:57:48 2018
@@ -3,6 +3,10 @@ $Id$
 
 ======================= 2.11-dev =====================
 
+CONNECTORS-1520: Transformation connector registration and de-registration was 
broken
+due to early cut/paste error.
+(Mike Hugo)
+
 CONNECTORS-1518: Elastic search without mapper attachment
 did not stream document.
 (Steph van Schwalk)

Modified: 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java?rev=1837084&r1=1837083&r2=1837084&view=diff
==============================================================================
--- 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
 (original)
+++ 
manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
 Mon Jul 30 18:57:48 2018
@@ -669,7 +669,7 @@ public class JobManager implements IJobM
     {
       if (currentCount == maxCount)
       {
-        noteConnectionDeregistration(list);
+        noteTransformationConnectionDeregistration(list);
         list.clear();
         currentCount = 0;
       }
@@ -728,7 +728,7 @@ public class JobManager implements IJobM
     {
       if (currentCount == maxCount)
       {
-        noteConnectionDeregistration(list);
+        noteTransformationConnectionRegistration(list);
         list.clear();
         currentCount = 0;
       }


Reply via email to