You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by ma...@apache.org on 2015/04/06 02:12:47 UTC

svn commit: r1671458 - in /oodt/trunk: CHANGES.txt resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java

Author: mattmann
Date: Mon Apr  6 00:12:46 2015
New Revision: 1671458

URL: http://svn.apache.org/r1671458
Log:
Fix for OODT-830: Queue Assertion failure of XmlQueueRepository under CAS Resource Manager contributed by Aditya Dhulipala <ad...@usc.edu> this closes #13

Modified:
    oodt/trunk/CHANGES.txt
    oodt/trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java

Modified: oodt/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/oodt/trunk/CHANGES.txt?rev=1671458&r1=1671457&r2=1671458&view=diff
==============================================================================
--- oodt/trunk/CHANGES.txt (original)
+++ oodt/trunk/CHANGES.txt Mon Apr  6 00:12:46 2015
@@ -2,6 +2,8 @@ Apache OODT Change Log
 ======================
 Release 0.9 - Current Development
 
+* OODT-830 Queue Assertion failure of XmlQueueRepository under CAS Resource Manager (Aditya Dhulipala via mattmann)
+
 * OODT-823 OODT JDK8 Maven3 build errors (Aditya Dhulipala via mattmann)
 
 * OODT-715 SolrIndexer fails to index when numProducts == pageSize (pramirez, mdstarch via mattmann)

Modified: oodt/trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java
URL: http://svn.apache.org/viewvc/oodt/trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java?rev=1671458&r1=1671457&r2=1671458&view=diff
==============================================================================
--- oodt/trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java (original)
+++ oodt/trunk/resource/src/main/java/org/apache/oodt/cas/resource/scheduler/QueueManager.java Mon Apr  6 00:12:46 2015
@@ -21,7 +21,7 @@ package org.apache.oodt.cas.resource.sch
 import org.apache.oodt.cas.resource.structs.exceptions.QueueManagerException;
 
 //JDK imports
-import java.util.HashMap;
+import java.util.LinkedHashMap;
 import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Map;
@@ -41,7 +41,7 @@ public class QueueManager {
 	protected Map<String, LinkedHashSet<String>> queueToNodesMapping;
 	
 	public QueueManager() {
-		this.queueToNodesMapping = new HashMap<String, LinkedHashSet<String>>();
+		this.queueToNodesMapping = new LinkedHashMap<String, LinkedHashSet<String>>();
 	}
 	
 	public synchronized boolean containsQueue(String queueName) {