[Cse-ip-svn-commits] SF.net SVN: cse-ip:[400] trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/ java/de/campussource/cse/core/DependencyManagerImpl.java

[<pka...@us...>]

Revision: 400
          http://cse-ip.svn.sourceforge.net/cse-ip/?rev=400&view=rev
Author:   pkasprzak
Date:     2009-07-29 21:50:19 +0000 (Wed, 29 Jul 2009)

Log Message:
-----------
* Fix query

Modified Paths:
--------------
    trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java

Modified: trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java
===================================================================
--- trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java	2009-07-29 20:59:13 UTC (rev 399)
+++ trunk/sandbox/lsf-adapter-demo/CSECore-ejb/src/java/de/campussource/cse/core/DependencyManagerImpl.java	2009-07-29 21:50:19 UTC (rev 400)
@@ -82,18 +82,19 @@
     // ----------------------------------------------------------------------------------------------------------------
     protected WaitingProcess getWaitingProcess(int entityId, String system) {
 
-        WaitingProcess process = (WaitingProcess) em.createNamedQuery(WaitingProcess.QUERY_getByEntityIdAndSystem). setParameter("system",      system).
-                                                                                                                    setParameter("entityId",    entityId).
-                                                                                                                    getSingleResult();
-        if (process == null) {
+        List<WaitingProcess> processes = em.createNamedQuery(WaitingProcess.QUERY_getByEntityIdAndSystem).  setParameter("system",      system).
+                                                                                                            setParameter("entityId",    entityId).
+                                                                                                            getResultList();
+        if (processes.isEmpty()) {
             /* No existing process found => create a new one */
-            process = new WaitingProcess();
+            WaitingProcess process = new WaitingProcess();
             process.setEntityId(entityId);
             process.setSystem(system);
             em.persist(process);
+            return process;
         }
 
-        return process;
+        return processes.get(0);
     }
 
     // ----------------------------------------------------------------------------------------------------------------


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.