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/master Commit: b6f8e711c7a0eb2334a0b92cd826615d0b413392 Parents: 4fa6749 Author: Shawn Feldman <[email protected]> Authored: Fri Oct 16 15:08:11 2015 -0600 Committer: Shawn Feldman <[email protected]> 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); }
