usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From snoopd...@apache.org
Subject [12/30] usergrid git commit: change queue impl
Date Wed, 21 Oct 2015 14:03:48 GMT
change queue impl


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/b6f8e711
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/b6f8e711
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/b6f8e711

Branch: refs/heads/usergrid-1007-shiro-cache
Commit: b6f8e711c7a0eb2334a0b92cd826615d0b413392
Parents: 4fa6749
Author: Shawn Feldman <sfeldman@apache.org>
Authored: Fri Oct 16 15:08:11 2015 -0600
Committer: Shawn Feldman <sfeldman@apache.org>
Committed: Fri Oct 16 15:08:11 2015 -0600

----------------------------------------------------------------------
 .../org/apache/usergrid/persistence/queue/DefaultQueueManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/b6f8e711/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
index ae0b0aa..a6bc8cf 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
@@ -49,7 +49,7 @@ public class DefaultQueueManager implements QueueManager {
                 if (message != null) {
                     returnQueue.add(message);
                 }
-            }while(message!=null && count-->0);
+            }while(queue.size()>0 && count-->0);
         }catch (InterruptedException ie){
             throw new RuntimeException(ie);
         }


Mime
View raw message