You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2014/11/04 19:39:31 UTC
svn commit: r1636686 - in /manifoldcf/branches/dev_1x: ./ framework/
framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java
Author: kwright
Date: Tue Nov 4 18:39:30 2014
New Revision: 1636686
URL: http://svn.apache.org/r1636686
Log:
Pull up another fix for CONNECTORS-1091 from trunk.
Modified:
manifoldcf/branches/dev_1x/ (props changed)
manifoldcf/branches/dev_1x/framework/ (props changed)
manifoldcf/branches/dev_1x/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java
Propchange: manifoldcf/branches/dev_1x/
------------------------------------------------------------------------------
Merged /manifoldcf/trunk:r1636684
Propchange: manifoldcf/branches/dev_1x/framework/
------------------------------------------------------------------------------
Merged /manifoldcf/trunk/framework:r1636684
Modified: manifoldcf/branches/dev_1x/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/dev_1x/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java?rev=1636686&r1=1636685&r2=1636686&view=diff
==============================================================================
--- manifoldcf/branches/dev_1x/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java (original)
+++ manifoldcf/branches/dev_1x/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobQueue.java Tue Nov 4 18:39:30 2014
@@ -218,6 +218,10 @@ public class JobQueue extends org.apache
map.put(docPriorityField,nullDocPriority);
performUpdate(map,"WHERE "+docPriorityField+" IS NULL",null,null);
+ map = new HashMap();
+ map.put(prioritySetField,new Long(0L));
+ performUpdate(map,"WHERE "+prioritySetField+" IS NULL",null,null);
+
// Also, add processIDField
if (existing.get(processIDField) == null)
{
@@ -903,7 +907,7 @@ public class JobQueue extends org.apache
throws ManifoldCFException
{
HashMap map = new HashMap();
- map.put(prioritySetField,null);
+ map.put(prioritySetField,new Long(0L));
map.put(docPriorityField,nullDocPriority);
ArrayList list = new ArrayList();
String query = buildConjunctionClause(list,new ClauseDescription[]{
@@ -932,7 +936,7 @@ public class JobQueue extends org.apache
checkTimeValue = null;
// Remove document priority; we don't want to pollute the queue. See CONNECTORS-290.
map.put(docPriorityField,nullDocPriority);
- map.put(prioritySetField,null);
+ map.put(prioritySetField,new Long(0L));
break;
case STATUS_ACTIVENEEDRESCAN:
case STATUS_ACTIVENEEDRESCANPURGATORY: