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 <[email protected]> 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) {
